This is an automated email from the ASF dual-hosted git repository. mayanks pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push: new f17839a get parameters in logging statement right way round (#7963) f17839a is described below commit f17839ad93ffa794f142eb5b72bc4315d70d74fb Author: Richard Startin <rich...@startree.ai> AuthorDate: Thu Jan 6 02:39:23 2022 +0000 get parameters in logging statement right way round (#7963) --- .../core/data/manager/realtime/LLRealtimeSegmentDataManager.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 b56a794..7f78b4d 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 @@ -398,8 +398,8 @@ public class LLRealtimeSegmentDataManager extends RealtimeSegmentDataManager { messageBatch = _partitionGroupConsumer .fetchMessages(_currentOffset, null, _partitionLevelStreamConfig.getFetchTimeoutMillis()); if (_segmentLogger.isDebugEnabled()) { - _segmentLogger.debug("message batch received. filter={} unfiltered={} endOfPartitionGroup={}", - messageBatch.getUnfilteredMessageCount(), messageBatch.getMessageCount(), + _segmentLogger.debug("message batch received. filtered={} unfiltered={} endOfPartitionGroup={}", + messageBatch.getMessageCount(), messageBatch.getUnfilteredMessageCount(), messageBatch.isEndOfPartitionGroup()); } _endOfPartitionGroup = messageBatch.isEndOfPartitionGroup(); --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org For additional commands, e-mail: commits-h...@pinot.apache.org