fix 代码merge的问题

dapeng · dapeng · commit ae6784f040ba · 2020-05-13T14:46:03.000+08:00
diff --git a/core/src/main/java/com/dtstack/flink/sql/side/SideSqlExec.java b/core/src/main/java/com/dtstack/flink/sql/side/SideSqlExec.java
@@ -787,10 +787,6 @@ private void joinFun(Object pollObj, Map<String, Table> localTableCache,
             throw new RuntimeException("can't not find side table:" + joinInfo.getRightTableName());
         }
 
-//        if(!checkJoinCondition(joinInfo.getCondition(), joinInfo.getRightTableAlias(), sideTableInfo)){
-//            throw new RuntimeException("ON condition must contain all equal fields!!!");
-//        }
-
         rightScopeChild.setRowTypeInfo(sideTableInfo.getRowTypeInfo());
 
         joinScope.addScope(leftScopeChild);

Original file line number	Diff line number	Diff line change
`@@ -787,10 +787,6 @@ private void joinFun(Object pollObj, Map<String, Table> localTableCache,`
`787`	`787`	`throw new RuntimeException("can't not find side table:" + joinInfo.getRightTableName());`
`788`	`788`	`}`
`789`	`789`
`790`		`-// if(!checkJoinCondition(joinInfo.getCondition(), joinInfo.getRightTableAlias(), sideTableInfo)){`
`791`		`-// throw new RuntimeException("ON condition must contain all equal fields!!!");`
`792`		`-// }`
`793`		`-`
`794`	`790`	`rightScopeChild.setRowTypeInfo(sideTableInfo.getRowTypeInfo());`
`795`	`791`
`796`	`792`	`joinScope.addScope(leftScopeChild);`