[hotfix-34950][core]Modify the reference name to the object
@@ -227,17 +227,17 @@ public class ExecuteProcessHelper {
SqlNode sqlNode = flinkPlanner.getParser().parse(realSql);
String tmpSql = ((SqlInsert) sqlNode).getSource().toString();
tmp.setExecSql(tmpSql);
- sideSqlExec.exec(tmp.getExecSql(), sideTableMap, tableEnv, registerTableCache, tmp, scope + "");
+ sideSqlExec.exec(tmp.getExecSql(), tmpTableMap, tableEnv, registerTableCache, tmp, scope + "");
} else {
for (String sourceTable : result.getSourceTableList()) {
- if (sideTableMap.containsKey(sourceTable)) {
+ if (tmpTableMap.containsKey(sourceTable)) {
isSide = true;
break;
}
}
if (isSide) {
//sql-dimensional table contains the dimension table of execution
- sideSqlExec.exec(result.getExecSql(), sideTableMap, tableEnv, registerTableCache, null, String.valueOf(scope));
+ sideSqlExec.exec(result.getExecSql(), tmpTableMap, tableEnv, registerTableCache, null, String.valueOf(scope));
} else {
LOG.info("----------exec sql without dimension join-----------");
LOG.info("----------real sql exec is--------------------------\n{}", result.getExecSql());
