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();