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");