[flink] branch master updated: [hotfix][kafka] Add claryfiying comment in FlinkKafkaProducer011

[pn...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

pnowojski pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 552ae2b  [hotfix][kafka] Add claryfiying comment in FlinkKafkaProducer011
552ae2b is described below

commit 552ae2b7caf3b812ed82e7ff65321ef48c2a3e35
Author: Piotr Nowojski <pi...@gmail.com>
AuthorDate: Tue Jul 24 10:00:38 2018 +0200

    [hotfix][kafka] Add claryfiying comment in FlinkKafkaProducer011
---
 .../apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git a/flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java b/flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java
index 8497372..b4416e8 100644
--- a/flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java
+++ b/flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java
@@ -916,6 +916,7 @@ public class FlinkKafkaProducer011<IN>
 		for (String transactionalId : transactionalIds) {
 			try (FlinkKafkaProducer<byte[], byte[]> kafkaProducer =
 					initTransactionalProducer(transactionalId, false)) {
+				// it suffice to call initTransactions - this will abort any lingering transactions
 				kafkaProducer.initTransactions();
 			}
 		}