@@ -214,7 +214,7 @@ private static void sqlTranslation(String localSqlPluginPath,
214214 for (InsertSqlParser .SqlParseResult result : sqlTree .getExecSqlList ()) {
215215 // prevent current sql use last sql's sideTableInfo
216216 sideTableMap .forEach ((s , abstractSideTableInfo ) -> tmpTableMap .put (s , SerializationUtils .clone (abstractSideTableInfo )));
217-
217+
218218 if (LOG .isInfoEnabled ()) {
219219 LOG .info ("exe-sql:\n " + result .getExecSql ());
220220 }
@@ -227,17 +227,17 @@ private static void sqlTranslation(String localSqlPluginPath,
227227 SqlNode sqlNode = flinkPlanner .getParser ().parse (realSql );
228228 String tmpSql = ((SqlInsert ) sqlNode ).getSource ().toString ();
229229 tmp .setExecSql (tmpSql );
230- sideSqlExec .exec (tmp .getExecSql (), sideTableMap , tableEnv , registerTableCache , tmp , scope + "" );
230+ sideSqlExec .exec (tmp .getExecSql (), tmpTableMap , tableEnv , registerTableCache , tmp , scope + "" );
231231 } else {
232232 for (String sourceTable : result .getSourceTableList ()) {
233- if (sideTableMap .containsKey (sourceTable )) {
233+ if (tmpTableMap .containsKey (sourceTable )) {
234234 isSide = true ;
235235 break ;
236236 }
237237 }
238238 if (isSide ) {
239239 //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 ));
241241 } else {
242242 LOG .info ("----------exec sql without dimension join-----------" );
243243 LOG .info ("----------real sql exec is--------------------------\n {}" , result .getExecSql ());
0 commit comments