Skip to content

Commit 2bfd651

Browse files
author
dapeng
committed
先去除join维表的条件校验
1 parent aa1b250 commit 2bfd651

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

core/src/main/java/com/dtstack/flink/sql/side/SideSqlExec.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -782,9 +782,9 @@ private void joinFun(Object pollObj, Map<String, Table> localTableCache,
782782
throw new RuntimeException("can't not find side table:" + joinInfo.getRightTableName());
783783
}
784784

785-
if(!checkJoinCondition(joinInfo.getCondition(), joinInfo.getRightTableAlias(), sideTableInfo)){
786-
throw new RuntimeException("ON condition must contain all equal fields!!!");
787-
}
785+
// if(!checkJoinCondition(joinInfo.getCondition(), joinInfo.getRightTableAlias(), sideTableInfo)){
786+
// throw new RuntimeException("ON condition must contain all equal fields!!!");
787+
// }
788788

789789
rightScopeChild.setRowTypeInfo(sideTableInfo.getRowTypeInfo());
790790

0 commit comments

Comments
 (0)