[pinot] branch master updated: [multistage] Optimize hasNext in RoundRobinScheduler (#10141)

[rongr]

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 <ankitsult...@uber.com>
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: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org