fixup! [FLINK-36368] Optimize global committers

apache · Oct 8, 2024 · b23171d · b23171d
1 parent a29a943
commit b23171d
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...rc/main/java/org/apache/flink/streaming/api/transformations/GlobalCommitterTransform.java b/...rc/main/java/org/apache/flink/streaming/api/transformations/GlobalCommitterTransform.java
@@ -18,6 +18,7 @@
 
 package org.apache.flink.streaming.api.transformations;
 
+import org.apache.flink.annotation.Internal;
 import org.apache.flink.api.common.typeinfo.Types;
 import org.apache.flink.api.connector.sink2.Committer;
 import org.apache.flink.api.dag.Transformation;
@@ -40,6 +41,7 @@
  *
  * @param <CommT>
  */
+@Internal
 public class GlobalCommitterTransform<CommT> extends TransformationWithLineage<Void> {
 
     private final DataStream<CommittableMessage<CommT>> inputStream;