解决偶发性 实例不执行BUG

byit-myth-core/myth-admin-core/src/main/java/com/byit/service/mapservice/impl/TaskAndLogServerImpl.java

@@ -157,6 +157,7 @@ public class TaskAndLogServerImpl implements TaskAndLogServer {
                     .isInner(FlowPropertyEnum.IS_INNER.getCode())
                     .failFast(RunRecordingEnum.FAIL_FAST_YES.getCode())
                     .workspaceId(virFlow.getWorkspaceId())
+                    .extendedConfiguration(virFlow.getExtendedConfiguration())
                     .build();
             runRecordingService.saveRunRecording(runRecording);
             log.error("在将该虚节点对应的节点拉取过来");

byit-myth-core/myth-admin-core/src/main/java/com/byit/strategy/task/java/JavaParamWrappedCallback.java

@@ -54,9 +54,6 @@ public class JavaParamWrappedCallback implements TaskRunTheLifeCycleCallback {
         if(runRecording != null) {
             String extendedConfiguration = runRecording.getExtendedConfiguration();
             FlowExtendedConfiguration flowExtendedConfiguration = JSON.parseObject(extendedConfiguration, FlowExtendedConfiguration.class);
-            if (flowExtendedConfiguration == null) {
-                flowExtendedConfiguration = new FlowExtendedConfiguration();
-            }
 
             String publicParam = flowExtendedConfiguration.getPublicParam();
             Map<String,String> publicMap = JSON.parseObject(publicParam, Map.class);
@@ -66,13 +63,12 @@ public class JavaParamWrappedCallback implements TaskRunTheLifeCycleCallback {
 
 
             runParamWrapped.setPublicParamMap(publicMap);
-            jobTaskSchedule.setExtendedConfiguration(JSON.toJSONString(flowExtendedConfiguration));
+
         }
 
         String runParam = jobTaskSchedule.getRunParam();
         runParamWrapped.setPrivateParam(runParam);
 
         jobTaskSchedule.setRunParam(JSON.toJSONString(runParamWrapped));
-
     }
 }