You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by ja...@apache.org on 2023/01/30 21:49:04 UTC
[pinot] branch master updated: Fix a typo in ready to consume check (#10204)
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 0a774844c8 Fix a typo in ready to consume check (#10204)
0a774844c8 is described below
commit 0a774844c888ffc14ab367dda78146ddb3fd5951
Author: Xiaotian (Jackie) Jiang <17...@users.noreply.github.com>
AuthorDate: Mon Jan 30 13:48:57 2023 -0800
Fix a typo in ready to consume check (#10204)
---
.../pinot/core/data/manager/realtime/LLRealtimeSegmentDataManager.java | 2 +-
1 file changed, 1 insertion(+), 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 b3607e6a06..7fe3239dcd 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
@@ -405,7 +405,7 @@ public class LLRealtimeSegmentDataManager extends RealtimeSegmentDataManager {
do {
//noinspection BusyWait
Thread.sleep(RealtimeTableDataManager.READY_TO_CONSUME_DATA_CHECK_INTERVAL_MS);
- } while (!_shouldStop && !endCriteriaReached() && _isReadyToConsumeData.getAsBoolean());
+ } while (!_shouldStop && !endCriteriaReached() && !_isReadyToConsumeData.getAsBoolean());
}
_numRowsErrored = 0;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org