Remove Internal annotation

apache · Oct 1, 2024 · 1b6daac · 1b6daac
1 parent 1c6bcda
commit 1b6daac
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/.../flink/src/main/java/org/apache/iceberg/flink/maintenance/api/MaintenanceTaskBuilder.java b/.../flink/src/main/java/org/apache/iceberg/flink/maintenance/api/MaintenanceTaskBuilder.java
@@ -20,7 +20,6 @@
 
 import java.time.Duration;
 import org.apache.flink.annotation.Experimental;
-import org.apache.flink.annotation.Internal;
 import org.apache.flink.api.common.operators.util.OperatorValidationUtils;
 import org.apache.flink.streaming.api.datastream.DataStream;
 import org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator;
@@ -185,12 +184,10 @@ protected String operatorName(String operatorNameBase) {
     return operatorNameBase + "[" + index() + "]";
   }
 
-  @Internal
   TriggerEvaluator evaluator() {
     return triggerEvaluator.build();
   }
 
-  @Internal
   DataStream<TaskResult> append(
       DataStream<Trigger> sourceStream,
       int defaultTaskIndex,