Merge branch 'hotfix_1.10_4.0.x_32715' into 1.10_release_4.0.x

Author: gituser

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

@@ -76,6 +76,7 @@
 import java.util.Optional;
 import java.util.Queue;
 import java.util.Set;
+import java.util.concurrent.atomic.AtomicBoolean;
 
 import static org.apache.calcite.sql.SqlKind.AS;
 import static org.apache.calcite.sql.SqlKind.INSERT;
@@ -562,7 +563,13 @@ private void joinFun(Object pollObj,
                 EnvironmentSettings.DEFAULT_BUILTIN_CATALOG,
                 EnvironmentSettings.DEFAULT_BUILTIN_DATABASE,
                 targetTableName);
-        boolean tableExists = tableEnv.getCatalog(EnvironmentSettings.DEFAULT_BUILTIN_CATALOG).get().tableExists(objectIdentifier.toObjectPath());
+        boolean tableExists = false;
+        for (String table : tableEnv.listTables()) {
+            if (table.equals(targetTableName)) {
+                tableExists = true;
+                break;
+            }
+        }
 
         if (!tableExists) {
             Table joinTable = tableEnv.fromDataStream(dsOut);