Merge branch 'hotfix_1.8_3.10.x_27836' into 1.8_release_3.10.x

gituser · gituser · commit 0d891958523e · 2020-07-29T17:11:44.000+08:00
diff --git a/core/src/main/java/com/dtstack/flink/sql/side/BaseSideInfo.java b/core/src/main/java/com/dtstack/flink/sql/side/BaseSideInfo.java
@@ -162,7 +162,7 @@ public void dealOneEqualCon(SqlNode sqlNode, String sideTableName){
                 }
             }
             if(equalFieldIndex == -1){
-                throw new RuntimeException("can't find equal field " + rightField);
+                throw new RuntimeException("can't find equal field " + leftField);
             }
 
             equalValIndex.add(equalFieldIndex);

Original file line number	Diff line number	Diff line change
`@@ -162,7 +162,7 @@ public void dealOneEqualCon(SqlNode sqlNode, String sideTableName){`
`162`	`162`	`}`
`163`	`163`	`}`
`164`	`164`	`if(equalFieldIndex == -1){`
`165`		`- throw new RuntimeException("can't find equal field " + rightField);`
	`165`	`+ throw new RuntimeException("can't find equal field " + leftField);`
`166`	`166`	`}`
`167`	`167`
`168`	`168`	`equalValIndex.add(equalFieldIndex);`