ignore appconn engine reuseEngine param

WeDataSphere · Apr 7, 2024 · 86b8198 · 86b8198
1 parent 2c317fe
commit 86b8198
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/...va/com/webank/wedatasphere/dss/linkis/node/execution/service/impl/BuildJobActionImpl.java b/...va/com/webank/wedatasphere/dss/linkis/node/execution/service/impl/BuildJobActionImpl.java
@@ -140,7 +140,7 @@ public JobSubmitAction getSubmitAction(Job job) throws LinkisJobExecutionErrorEx
 
 
         //是否复用引擎，不复用就为空
-        if(!isReuseEngine(job.getParams())){
+        if(!isAppconnJob(job) && !isReuseEngine(job.getParams())){
             labels.put("executeOnce", "");
         }
         Map<String, Object> paramMapCopy = (HashMap<String, Object>) SerializationUtils.clone(new HashMap<String, Object>(job.getParams()));
@@ -190,6 +190,13 @@ public boolean isReuseEngine(Map<String, Object> params) {
         return true;
     }
 
+    /**
+     * 是否为appconnjob
+     */
+    private boolean isAppconnJob(Job job){
+        return APPCONN.equals(job.getEngineType());
+    }
+
     /**
      * spark自定义参数配置输入，例如spark.sql.shuffle.partitions=10。多个参数使用分号分隔。
      *