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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
