(flink) 04/08: [FLINK-35359][config] Mark internally used option Internal

[xtsong]

This is an automated email from the ASF dual-hosted git repository.

xtsong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 1a59c53b809db129438f6ff10f24560658347840
Author: sxnan <suxuanna...@gmail.com>
AuthorDate: Mon May 20 15:19:12 2024 +0800

    [FLINK-35359][config] Mark internally used option Internal
---
 .../org/apache/flink/table/utils/python/PythonDynamicTableOptions.java | 2 ++
 .../src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java  | 3 ++-
 .../java/org/apache/flink/runtime/entrypoint/ClusterEntrypoint.java    | 2 ++
 .../flink/runtime/entrypoint/component/FileJobGraphRetriever.java      | 2 ++
 4 files changed, 8 insertions(+), 1 deletion(-)

diff --git 
a/flink-python/src/main/java/org/apache/flink/table/utils/python/PythonDynamicTableOptions.java
 
b/flink-python/src/main/java/org/apache/flink/table/utils/python/PythonDynamicTableOptions.java
index 68d748842d2..33a6cacc9d5 100644
--- 
a/flink-python/src/main/java/org/apache/flink/table/utils/python/PythonDynamicTableOptions.java
+++ 
b/flink-python/src/main/java/org/apache/flink/table/utils/python/PythonDynamicTableOptions.java
@@ -18,10 +18,12 @@
 
 package org.apache.flink.table.utils.python;
 
+import org.apache.flink.annotation.Internal;
 import org.apache.flink.configuration.ConfigOption;
 import org.apache.flink.configuration.ConfigOptions;
 
 /** Options for PythonDynamicTableSource. */
+@Internal
 public class PythonDynamicTableOptions {
 
     public static final ConfigOption<String> INPUT_FILE_PATH =
diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
index e138147d97d..0229131bd75 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
@@ -18,6 +18,7 @@
 
 package org.apache.flink.runtime.dispatcher;
 
+import org.apache.flink.annotation.Internal;
 import org.apache.flink.annotation.VisibleForTesting;
 import org.apache.flink.api.common.JobID;
 import org.apache.flink.api.common.JobStatus;
@@ -140,7 +141,7 @@ import static 
org.apache.flink.util.Preconditions.checkNotNull;
 public abstract class Dispatcher extends FencedRpcEndpoint<DispatcherId>
         implements DispatcherGateway {
 
-    @VisibleForTesting
+    @VisibleForTesting @Internal
     public static final ConfigOption<Duration> CLIENT_ALIVENESS_CHECK_DURATION 
=
             
ConfigOptions.key("$internal.dispatcher.client-aliveness-check.interval")
                     .durationType()
diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypoint.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypoint.java
index 8c2803fe443..66de2da1c45 100755
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypoint.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypoint.java
@@ -18,6 +18,7 @@
 
 package org.apache.flink.runtime.entrypoint;
 
+import org.apache.flink.annotation.Internal;
 import org.apache.flink.api.common.time.Time;
 import org.apache.flink.configuration.BlobServerOptions;
 import org.apache.flink.configuration.ClusterOptions;
@@ -112,6 +113,7 @@ import java.util.concurrent.atomic.AtomicBoolean;
  */
 public abstract class ClusterEntrypoint implements AutoCloseableAsync, 
FatalErrorHandler {
 
+    @Internal
     public static final ConfigOption<String> INTERNAL_CLUSTER_EXECUTION_MODE =
             ConfigOptions.key("internal.cluster.execution-mode")
                     .stringType()
diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/FileJobGraphRetriever.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/FileJobGraphRetriever.java
index c360da1a1fa..b7950ea7045 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/FileJobGraphRetriever.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/FileJobGraphRetriever.java
@@ -18,6 +18,7 @@
 
 package org.apache.flink.runtime.entrypoint.component;
 
+import org.apache.flink.annotation.Internal;
 import org.apache.flink.configuration.ConfigOption;
 import org.apache.flink.configuration.ConfigOptions;
 import org.apache.flink.configuration.Configuration;
@@ -44,6 +45,7 @@ import static 
org.apache.flink.util.Preconditions.checkNotNull;
  */
 public class FileJobGraphRetriever extends 
AbstractUserClassPathJobGraphRetriever {
 
+    @Internal
     public static final ConfigOption<String> JOB_GRAPH_FILE_PATH =
             
ConfigOptions.key("internal.jobgraph-path").stringType().defaultValue("job.graph");