You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2020/06/15 17:14:51 UTC
[flink] 02/04: [minor] In FlinkKafkaInternalProducer add Javadoc to
internal enqueueNewPartitions()
This is an automated email from the ASF dual-hosted git repository.
aljoscha pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 60c38bd4674a61f833e148bedc95e60dd6fbce10
Author: Aljoscha Krettek <al...@apache.org>
AuthorDate: Wed Apr 8 15:12:59 2020 +0200
[minor] In FlinkKafkaInternalProducer add Javadoc to internal enqueueNewPartitions()
---
.../connectors/kafka/internal/FlinkKafkaInternalProducer.java | 7 +++++++
1 file changed, 7 insertions(+)
diff --git a/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/FlinkKafkaInternalProducer.java b/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/FlinkKafkaInternalProducer.java
index 7d41c23..e4e7b5c 100644
--- a/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/FlinkKafkaInternalProducer.java
+++ b/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/FlinkKafkaInternalProducer.java
@@ -286,6 +286,13 @@ public class FlinkKafkaInternalProducer<K, V> implements Producer<K, V> {
result.await();
}
+ /**
+ * Enqueues new transactions at the transaction manager and returns a {@link
+ * TransactionalRequestResult} that allows waiting on them.
+ *
+ * <p>If there are no new transactions we return a {@link TransactionalRequestResult} that is
+ * already done.
+ */
private TransactionalRequestResult enqueueNewPartitions() {
Object transactionManager = getField(kafkaProducer, "transactionManager");
synchronized (transactionManager) {