Merge branch '1.8_release_3.10.x' into 1.8_release_4.0.x

gituser · gituser · commit 988c3792032d · 2020-07-29T17:13:15.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);`