[Bug] Fix the issue where metrics do not update upon restart. (#4148)

Co-authored-by: yuhang2.zhang <[email protected]>
apache · Dec 19, 2024 · 13ac2c6 · 13ac2c6
1 parent 5fd4cfd
commit 13ac2c6
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...s/src/main/scala/org/apache/streampark/flink/kubernetes/watcher/FlinkMetricsWatcher.scala b/...s/src/main/scala/org/apache/streampark/flink/kubernetes/watcher/FlinkMetricsWatcher.scala
@@ -89,14 +89,14 @@ class FlinkMetricWatcher(conf: MetricWatcherConfig = MetricWatcherConfig.default
         future.onComplete(_.getOrElse(None) match {
           case Some(metric) =>
             val clusterKey = id.toClusterKey
-            // update current flink cluster metrics on cache
-            watchController.flinkMetrics.put(clusterKey, metric)
             val isMetricChanged = {
               val preMetric = watchController.flinkMetrics.get(clusterKey)
               preMetric == null || !preMetric.equalsPayload(metric)
             }
             if (isMetricChanged) {
               eventBus.postAsync(FlinkClusterMetricChangeEvent(id, metric))
+              // update current flink cluster metrics on cache
+              watchController.flinkMetrics.put(clusterKey, metric)
             }
           case _ =>
         })