[Imporve] changeStateEvnet equals improvements (#3603)

* [Imporve] changeStateEvnet equals improvements

* [Improve] trigger savepoint FE pop-window improvements

---------

Co-authored-by: benjobs <[email protected]>

Author: wolfboys

streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SavePointServiceImpl.java

@@ -265,15 +265,17 @@ public String getSavePointPath(Application appParam) throws Exception {
         if (!config.isEmpty()) {
           savepointPath = config.get(CheckpointingOptions.SAVEPOINT_DIRECTORY.key());
         }
-      } else {
-        // 3.2) At the yarn or k8s mode, then read the savepoint in flink-conf.yml in the bound
-        // flink
-        FlinkEnv flinkEnv = flinkEnvService.getById(application.getVersionId());
-        savepointPath =
-            flinkEnv.convertFlinkYamlAsMap().get(CheckpointingOptions.SAVEPOINT_DIRECTORY.key());
       }
     }
 
+    // 3.2) read the savepoint in flink-conf.yml in the bound
+    if (StringUtils.isBlank(savepointPath)) {
+      // flink
+      FlinkEnv flinkEnv = flinkEnvService.getById(application.getVersionId());
+      savepointPath =
+          flinkEnv.convertFlinkYamlAsMap().get(CheckpointingOptions.SAVEPOINT_DIRECTORY.key());
+    }
+
     return savepointPath;
   }
 

streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/FlinkAppHttpWatcher.java

@@ -845,12 +845,10 @@ public boolean equals(Object object) {
         return false;
       }
       StateChangeEvent that = (StateChangeEvent) object;
-      if (optionState != that.optionState) {
-        return false;
-      }
       return Objects.equals(id, that.id)
           && Objects.equals(jobId, that.jobId)
-          && appState == that.appState
+          && Objects.equals(appState, that.appState)
+          && Objects.equals(optionState, that.optionState)
           && Objects.equals(jobManagerUrl, that.jobManagerUrl);
     }
 

streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useSavepoint.tsx

@@ -106,6 +106,7 @@ export const useSavepoint = (updateOption: Fn) => {
               const { data } = await fetchCheckSavepointPath({ id: appId.value });
               if (data.data) {
                 await handleSavepointAction(savepointReq);
+                resolve(true);
               } else {
                 await createErrorSwal(data.message);
               }