[Fix]batch execution with yarn-app mode using the useBatchModel parameter

dlink-app/dlink-app-base/src/main/java/com/dlink/app/flinksql/Submiter.java

@@ -41,7 +41,7 @@ public class Submiter {
         }
         return "select id, name, alias as jobName, type,check_point as checkpoint," +
                 "save_point_path as savePointPath, parallelism,fragment as useSqlFragment,statement_set as useStatementSet,config_json as config," +
-                " env_id as envId from dlink_task where id = " + id;
+                " env_id as envId,batch_model AS useBatchModel from dlink_task where id = " + id;
     }
 
     private static String getFlinkSQLStatement(Integer id, DBConfig config) {

dlink-executor/src/main/java/com/dlink/executor/AppBatchExecutor.java

@@ -18,7 +18,7 @@ public class AppBatchExecutor extends Executor {
         this.executorSetting = executorSetting;
         if (Asserts.isNotNull(executorSetting.getConfig())) {
             Configuration configuration = Configuration.fromMap(executorSetting.getConfig());
-            this.environment = StreamExecutionEnvironment.createLocalEnvironment(configuration);
+            this.environment = StreamExecutionEnvironment.getExecutionEnvironment(configuration);
         } else {
             this.environment = StreamExecutionEnvironment.createLocalEnvironment();
         }