This is an automated email from the ASF dual-hosted git repository.
jackie 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 022fd37d24 Fix message count (#9271)
022fd37d24 is described below
commit 022fd37d24af7156c47ffa9c6f02e0c4e7b42e44
Author: Xiaotian (Jackie) Jiang <[email protected]>
AuthorDate: Tue Aug 23 16:11:00 2022 -0700
Fix message count (#9271)
---
.../pinot/core/data/manager/realtime/LLRealtimeSegmentDataManager.java | 3 +--
1 file changed, 1 insertion(+), 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 2fe8f47f10..d3d44e7039 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
@@ -498,8 +498,7 @@ public class LLRealtimeSegmentDataManager extends
RealtimeSegmentDataManager {
* otherwise
*/
private boolean processStreamEvents(MessageBatch messagesAndOffsets, long
idlePipeSleepTimeMillis) {
-
- int messageCount = messagesAndOffsets.getUnfilteredMessageCount();
+ int messageCount = messagesAndOffsets.getMessageCount();
_rateLimiter.throttle(messageCount);
PinotMeter realtimeRowsConsumedMeter = null;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
