You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by am...@apache.org on 2025/02/28 14:55:55 UTC
(ignite-3) 04/05: Fix HashJoin node failure for SEMI join
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a commit to branch ignite-24675
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
commit c84b1d0956b9c6e0aaf92f7eb24c053510c0823d
Author: amashenkov <am...@apache.org>
AuthorDate: Fri Feb 28 17:37:25 2025 +0300
Fix HashJoin node failure for SEMI join
---
.../org/apache/ignite/internal/sql/engine/exec/rel/HashJoinNode.java | 4 ----
1 file changed, 4 deletions(-)
diff --git a/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/HashJoinNode.java b/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/HashJoinNode.java
index b12165f22f6..610820217a5 100644
--- a/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/HashJoinNode.java
+++ b/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/HashJoinNode.java
@@ -583,10 +583,6 @@ public abstract class HashJoinNode<RowT> extends AbstractRightMaterializedJoinNo
requested--;
downstream().push(left);
-
- if (requested == 0) {
- break;
- }
}
left = null;