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 <108396409+jjiach...@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();

Reply via email to