(flink) 02/03: [FLINK-34190][checkpoint][rest] Deprecation message of RestoreMode#LEGACY in REST API

[hangxiang]

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

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

commit eeb42498a0df398a6e7fa35be56d3217c063194f
Author: Zakelly <zakelly....@gmail.com>
AuthorDate: Wed Jan 24 00:25:35 2024 +0800

    [FLINK-34190][checkpoint][rest] Deprecation message of RestoreMode#LEGACY 
in REST API
---
 .../apache/flink/runtime/webmonitor/handlers/JarRunHandler.java    | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git 
a/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JarRunHandler.java
 
b/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JarRunHandler.java
index 3299bfac4d2..7be26258973 100644
--- 
a/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JarRunHandler.java
+++ 
b/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JarRunHandler.java
@@ -155,6 +155,13 @@ public class JarRunHandler
                                 () ->
                                         effectiveConfiguration.get(
                                                 
SavepointConfigOptions.RESTORE_MODE));
+        if (restoreMode.equals(RestoreMode.LEGACY)) {
+            log.warn(
+                    "The {} restore mode is deprecated, please use {} or {} 
mode instead.",
+                    RestoreMode.LEGACY,
+                    RestoreMode.CLAIM,
+                    RestoreMode.NO_CLAIM);
+        }
         final SavepointRestoreSettings savepointRestoreSettings;
         if (savepointPath != null) {
             savepointRestoreSettings =