Skip to content

Commit 95e3896

Browse files
Savonitar1996fanrui
authored andcommitted
[hotfix] Fix misleading log message in setTransactionId
1 parent a0a071c commit 95e3896

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/FlinkKafkaInternalProducer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -179,7 +179,7 @@ public long getProducerId() {
179179
public void setTransactionId(String transactionalId) {
180180
checkState(
181181
!isInTransaction(),
182-
String.format("Another transaction %s is still open.", transactionalId));
182+
String.format("Another transaction %s is still open.", this.transactionalId));
183183
LOG.debug("Change transaction id from {} to {}", this.transactionalId, transactionalId);
184184
this.transactionalId = transactionalId;
185185
Object transactionManager = getTransactionManager();

0 commit comments

Comments
 (0)