You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by yu...@apache.org on 2022/10/20 03:10:19 UTC
[inlong] branch master updated: [INLONG-6188] join supports multiple fields (#6189)
This is an automated email from the ASF dual-hosted git repository.
yunqing pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/master by this push:
new 153fdaf96 [INLONG-6188] join supports multiple fields (#6189)
153fdaf96 is described below
commit 153fdaf967197d1a8b3c3558fb83e7987bc10716
Author: jiachengjiang <10...@users.noreply.github.com>
AuthorDate: Thu Oct 20 11:10:15 2022 +0800
[INLONG-6188] join supports multiple fields (#6189)
---
.../org/apache/inlong/manager/pojo/sort/util/NodeRelationUtils.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/NodeRelationUtils.java b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/NodeRelationUtils.java
index 69ab47153..5896e2887 100644
--- a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/NodeRelationUtils.java
+++ b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/NodeRelationUtils.java
@@ -148,7 +148,7 @@ public class NodeRelationUtils {
StreamField leftField = leftJoinFields.get(index);
StreamField rightField = rightJoinFields.get(index);
LogicOperator operator;
- if (index != leftJoinFields.size() - 1) {
+ if (index != 0) {
operator = AndOperator.getInstance();
} else {
operator = EmptyOperator.getInstance();