fix: flink metrics watch logic error

apache · Jan 10, 2025 · 0e33bfd · 0e33bfd
1 parent e3c6c46
commit 0e33bfd
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 &&