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 7aa9082dea801b918179d2f51f4ddb3e4348bc3a Author: Jack Li(Analytics Engineering) <[email protected]> AuthorDate: Wed Aug 18 11:12:17 2021 -0700 Only emit 0 for LLC_PARTITION_CONSUMING if LLRealtimeSegmentDataManager isn't stopped --- .../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..25a5dca 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 (!_shouldStop) { + _serverMetrics.setValueOfTableGauge(_metricKeyName, ServerGauge.LLC_PARTITION_CONSUMING, 0); + } } } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
