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