This is an automated email from the ASF dual-hosted git repository.
rongr 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 eaa60d93fb [multistage] Optimize hasNext in RoundRobinScheduler
(#10141)
eaa60d93fb is described below
commit eaa60d93fb032114db618d2f0ef329e6f8fb7cf2
Author: Ankit Sultana <[email protected]>
AuthorDate: Wed Jan 18 21:57:06 2023 +0530
[multistage] Optimize hasNext in RoundRobinScheduler (#10141)
---
.../org/apache/pinot/query/runtime/executor/RoundRobinScheduler.java | 3 +++
1 file changed, 3 insertions(+)
diff --git
a/pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/executor/RoundRobinScheduler.java
b/pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/executor/RoundRobinScheduler.java
index ee163468a3..3a20bf5d6a 100644
---
a/pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/executor/RoundRobinScheduler.java
+++
b/pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/executor/RoundRobinScheduler.java
@@ -115,6 +115,9 @@ public class RoundRobinScheduler implements
OpChainScheduler {
@Override
public boolean hasNext() {
+ if (!_ready.isEmpty()) {
+ return true;
+ }
computeReady();
return !_ready.isEmpty();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
