(incubator-streampark) 01/01: [Imporve] changeStateEvnet equals improvements

[benjobs]

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

benjobs pushed a commit to branch cp_sp
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git

commit 328970d51cbf56c6d72802820041e3a770d01d75
Author: benjobs <benj...@gmail.com>
AuthorDate: Thu Mar 7 07:41:53 2024 +0800

    [Imporve] changeStateEvnet equals improvements
---
 .../apache/streampark/console/core/task/FlinkAppHttpWatcher.java    | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/FlinkAppHttpWatcher.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/FlinkAppHttpWatcher.java
index 08a7f7902..1c721b455 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/FlinkAppHttpWatcher.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/FlinkAppHttpWatcher.java
@@ -845,12 +845,10 @@ public class FlinkAppHttpWatcher {
         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);
     }