fix: flink metrics watch logic error (#4160)

apache · Jan 11, 2025 · 86725fd · 86725fd
1 parent e3c6c46
commit 86725fd
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/model/FlinkMetricCV.scala b/...ubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/model/FlinkMetricCV.scala
@@ -56,7 +56,7 @@ case class FlinkMetricCV(
 
   def equalsPayload(another: FlinkMetricCV): Boolean = {
     groupId == another.groupId &&
-    totalJmMemory == another.totalTmMemory &&
+    totalJmMemory == another.totalJmMemory &&
     totalTmMemory == another.totalTmMemory &&
     totalTm == another.totalTm &&
     totalSlot == another.totalSlot &&