This is an automated email from the ASF dual-hosted git repository. jlli pushed a commit to branch fix-llc-segment-metric in repository https://gitbox.apache.org/repos/asf/pinot.git
commit dfcbcdefb23174230d0475a5dc3b59cdb917d79a Author: Jack Li(Analytics Engineering) <[email protected]> AuthorDate: Wed Aug 18 11:12:17 2021 -0700 Only emit 0 for LLC_PARTITION_CONSUMING if state is ERROR --- .../core/data/manager/realtime/LLRealtimeSegmentDataManager.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/LLRealtimeSegmentDataManager.java b/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/LLRealtimeSegmentDataManager.java index 87ed506..feaf1df 100644 --- a/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/LLRealtimeSegmentDataManager.java +++ b/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/LLRealtimeSegmentDataManager.java @@ -674,7 +674,9 @@ public class LLRealtimeSegmentDataManager extends RealtimeSegmentDataManager { .setValueOfTableGauge(_metricKeyName, ServerGauge.LAST_REALTIME_SEGMENT_COMPLETION_DURATION_SECONDS, TimeUnit.MILLISECONDS.toSeconds(now() - initialConsumptionEnd)); } - _serverMetrics.setValueOfTableGauge(_metricKeyName, ServerGauge.LLC_PARTITION_CONSUMING, 0); + if (_state == State.ERROR) { + _serverMetrics.setValueOfTableGauge(_metricKeyName, ServerGauge.LLC_PARTITION_CONSUMING, 0); + } } } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
