kfaraz commented on code in PR #18819:
URL: https://github.com/apache/druid/pull/18819#discussion_r2621805067
##########
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java:
##########
@@ -4381,6 +4374,39 @@ public ConcurrentHashMap<PartitionIdType,
SequenceOffsetType> getPartitionOffset
return partitionOffsets;
}
+ /**
+ * Calculates the average poll-idle-ratio metric across all active tasks.
+ * This metric indicates how much time the consumer spends idle waiting for
data.
+ *
+ * @return the average poll-idle-ratio across all tasks, or 1 (full idle) if
no tasks or metrics are available
Review Comment:
On second though, we might want to return -1 from here if we don't have any
metrics available.
This would cause the auto-scaler to skip scaling rather than make a bad
decision.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
