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 <[email protected]>
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();