From 1b6daac4fd5cbbf1ff648795d2f875bf4584e177 Mon Sep 17 00:00:00 2001
From: Peter Vary <peter_vary4@apple.com>
Date: Tue, 1 Oct 2024 15:52:21 +0200
Subject: [PATCH] Remove Internal annotation

---
 .../iceberg/flink/maintenance/api/MaintenanceTaskBuilder.java  | 3 ---
 1 file changed, 3 deletions(-)

diff --git a/flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/MaintenanceTaskBuilder.java b/flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/MaintenanceTaskBuilder.java
index 63076876e74d..647a29223020 100644
--- a/flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/MaintenanceTaskBuilder.java
+++ b/flink/v1.20/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,