bigfix

sishu@dtstack.com · sishu@dtstack.com · commit 94ea2a1bea0b · 2018-11-06T20:23:40.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
@@ -121,7 +121,7 @@ public void exec(String sql, Map<String, SideTableInfo> sideTableMap, StreamTabl
                 rightScopeChild.setTableName(joinInfo.getRightTableName());
                 SideTableInfo sideTableInfo = sideTableMap.get(joinInfo.getRightTableName());
                 if(sideTableInfo == null){
-                    sideTableInfo = sideTableMap.get(joinInfo.getRightTableName());
+                    sideTableInfo = sideTableMap.get(joinInfo.getRightTableAlias());
                 }
 
                 if(sideTableInfo == null){

Original file line number	Diff line number	Diff line change
`@@ -121,7 +121,7 @@ public void exec(String sql, Map<String, SideTableInfo> sideTableMap, StreamTabl`
`121`	`121`	`rightScopeChild.setTableName(joinInfo.getRightTableName());`
`122`	`122`	`SideTableInfo sideTableInfo = sideTableMap.get(joinInfo.getRightTableName());`
`123`	`123`	`if(sideTableInfo == null){`
`124`		`- sideTableInfo = sideTableMap.get(joinInfo.getRightTableName());`
	`124`	`+ sideTableInfo = sideTableMap.get(joinInfo.getRightTableAlias());`
`125`	`125`	`}`
`126`	`126`
`127`	`127`	`if(sideTableInfo == null){`