diff --git a/flink-runtime/src/main/java/org/apache/flink/streaming/api/transformations/GlobalCommitterTransform.java b/flink-runtime/src/main/java/org/apache/flink/streaming/api/transformations/GlobalCommitterTransform.java
index 71f28055bde29f..303c632259fab5 100644
--- a/flink-runtime/src/main/java/org/apache/flink/streaming/api/transformations/GlobalCommitterTransform.java
+++ b/flink-runtime/src/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;