From 935188f06a8a94b3a2c991a8aa6e48b2bfaeee70 Mon Sep 17 00:00:00 2001 From: Zhanghao Chen Date: Mon, 16 Oct 2023 19:43:13 +0800 Subject: [PATCH] [FLINK-33236][config] Deprecate the unused high-availability.zookeeper.path.running-registry option (#23506) --- .../generated/expert_high_availability_zk_section.html | 6 ------ .../generated/high_availability_configuration.html | 6 ------ .../flink/configuration/HighAvailabilityOptions.java | 7 ++++++- 3 files changed, 6 insertions(+), 13 deletions(-) diff --git a/docs/layouts/shortcodes/generated/expert_high_availability_zk_section.html b/docs/layouts/shortcodes/generated/expert_high_availability_zk_section.html index 2bfde8ceb6b87..102f589a36a5b 100644 --- a/docs/layouts/shortcodes/generated/expert_high_availability_zk_section.html +++ b/docs/layouts/shortcodes/generated/expert_high_availability_zk_section.html @@ -56,11 +56,5 @@ String ZooKeeper root path (ZNode) for job graphs - -
high-availability.zookeeper.path.running-registry
- "/running_job_registry/" - String - - diff --git a/docs/layouts/shortcodes/generated/high_availability_configuration.html b/docs/layouts/shortcodes/generated/high_availability_configuration.html index 6deb91d1b7cf6..9241237e9376b 100644 --- a/docs/layouts/shortcodes/generated/high_availability_configuration.html +++ b/docs/layouts/shortcodes/generated/high_availability_configuration.html @@ -86,12 +86,6 @@ String The root path under which Flink stores its entries in ZooKeeper. - -
high-availability.zookeeper.path.running-registry
- "/running_job_registry/" - String - -
high-availability.zookeeper.quorum
(none) diff --git a/flink-core/src/main/java/org/apache/flink/configuration/HighAvailabilityOptions.java b/flink-core/src/main/java/org/apache/flink/configuration/HighAvailabilityOptions.java index 5bb66031c2316..a96d300648e8d 100644 --- a/flink-core/src/main/java/org/apache/flink/configuration/HighAvailabilityOptions.java +++ b/flink-core/src/main/java/org/apache/flink/configuration/HighAvailabilityOptions.java @@ -167,11 +167,16 @@ public class HighAvailabilityOptions { .withDescription( "Defines the number of connection retries before the client gives up."); + /** @deprecated Don't use this option anymore. It has no effect on Flink. */ + @Deprecated @Documentation.Section(Documentation.Sections.EXPERT_ZOOKEEPER_HIGH_AVAILABILITY) public static final ConfigOption ZOOKEEPER_RUNNING_JOB_REGISTRY_PATH = key("high-availability.zookeeper.path.running-registry") .stringType() - .defaultValue("/running_job_registry/"); + .defaultValue("/running_job_registry/") + .withDescription( + "Don't use this option anymore. It has no effect on Flink. The RunningJobRegistry has been " + + "replaced by the JobResultStore in Flink 1.15."); @Documentation.Section(Documentation.Sections.EXPERT_ZOOKEEPER_HIGH_AVAILABILITY) public static final ConfigOption ZOOKEEPER_CLIENT_ACL =