Fix typo

xinyuiscool · Aug 21, 2024 · dd10f9b · dd10f9b
1 parent 567edcd
commit dd10f9b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/samza-core/src/main/java/org/apache/samza/operators/impl/WatermarkMetrics.java b/samza-core/src/main/java/org/apache/samza/operators/impl/WatermarkMetrics.java
@@ -45,7 +45,7 @@ void setAggregateTime(SystemStreamPartition systemStreamPartition, long time) {
 
   void setQuorumCount(SystemStream stream, int quorumCount) {
     final Gauge<Integer> gauge = quorumCounts.computeIfAbsent(stream,
-      ssp -> newGauge(String.format("%s-aggr-watermark", ssp.getStream()), 0));
+      ssp -> newGauge(String.format("%s-quorum-count", ssp.getStream()), 0));
     gauge.set(quorumCount);
   }
 }