Addressing review

apache · Nov 29, 2024 · 00e7ad6 · 00e7ad6
1 parent 49d6a5a
commit 00e7ad6
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...g/apache/flink/streaming/runtime/translators/GlobalCommitterTransformationTranslator.java b/...g/apache/flink/streaming/runtime/translators/GlobalCommitterTransformationTranslator.java
@@ -109,6 +109,7 @@ private static boolean hasUpstreamCommitter(DataStream<?> ds) {
                 StreamOperatorFactory<?> operatorFactory =
                         ((OneInputTransformation<?, ?>) transformation).getOperatorFactory();
                 if (operatorFactory instanceof CommitterOperatorFactory) {
+                    // found the committer, so the global committer should commit on input
                     return true;
                 }
                 if (operatorFactory instanceof SinkWriterOperatorFactory) {