@@ -214,7 +214,7 @@ private static void sqlTranslation(String localSqlPluginPath,
214
214
for (InsertSqlParser .SqlParseResult result : sqlTree .getExecSqlList ()) {
215
215
// prevent current sql use last sql's sideTableInfo
216
216
sideTableMap .forEach ((s , abstractSideTableInfo ) -> tmpTableMap .put (s , SerializationUtils .clone (abstractSideTableInfo )));
217
-
217
+
218
218
if (LOG .isInfoEnabled ()) {
219
219
LOG .info ("exe-sql:\n " + result .getExecSql ());
220
220
}
@@ -227,17 +227,17 @@ private static void sqlTranslation(String localSqlPluginPath,
227
227
SqlNode sqlNode = flinkPlanner .getParser ().parse (realSql );
228
228
String tmpSql = ((SqlInsert ) sqlNode ).getSource ().toString ();
229
229
tmp .setExecSql (tmpSql );
230
- sideSqlExec .exec (tmp .getExecSql (), sideTableMap , tableEnv , registerTableCache , tmp , scope + "" );
230
+ sideSqlExec .exec (tmp .getExecSql (), tmpTableMap , tableEnv , registerTableCache , tmp , scope + "" );
231
231
} else {
232
232
for (String sourceTable : result .getSourceTableList ()) {
233
- if (sideTableMap .containsKey (sourceTable )) {
233
+ if (tmpTableMap .containsKey (sourceTable )) {
234
234
isSide = true ;
235
235
break ;
236
236
}
237
237
}
238
238
if (isSide ) {
239
239
//sql-dimensional table contains the dimension table of execution
240
- sideSqlExec .exec (result .getExecSql (), sideTableMap , tableEnv , registerTableCache , null , String .valueOf (scope ));
240
+ sideSqlExec .exec (result .getExecSql (), tmpTableMap , tableEnv , registerTableCache , null , String .valueOf (scope ));
241
241
} else {
242
242
LOG .info ("----------exec sql without dimension join-----------" );
243
243
LOG .info ("----------real sql exec is--------------------------\n {}" , result .getExecSql ());
0 commit comments