small fix

linkedin · Feb 2, 2024 · 405bdeb · 405bdeb
1 parent 8ae7d24
commit 405bdeb
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...da-vinci-client/src/main/java/com/linkedin/davinci/kafka/consumer/StoreIngestionTask.java b/...da-vinci-client/src/main/java/com/linkedin/davinci/kafka/consumer/StoreIngestionTask.java
@@ -1309,13 +1309,13 @@ private void maybeUnsubscribeCompletedPartitions(Store store) {
 
   private void recordMaxIdleTime() {
     if (emitMetrics.get()) {
-      long maxIdleTime = 0;
+      long curTime = System.currentTimeMillis(), oldest = curTime;
       for (PartitionConsumptionState state: partitionConsumptionStateMap.values()) {
         if (state != null) {
-          maxIdleTime = Math.max(maxIdleTime, state.getLatestPolledMessageTimestampInMs());
+          oldest = Math.min(oldest, state.getLatestPolledMessageTimestampInMs());
         }
       }
-      versionedIngestionStats.recordMaxIdleTime(storeName, versionNumber, maxIdleTime);
+      versionedIngestionStats.recordMaxIdleTime(storeName, versionNumber, curTime - oldest);
     }
   }