File tree Expand file tree Collapse file tree 2 files changed +6
-3
lines changed
dolphinscheduler-scheduler-plugin/dolphinscheduler-scheduler-quartz/src/main/java/org/apache/dolphinscheduler/scheduler/quartz
dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process Expand file tree Collapse file tree 2 files changed +6
-3
lines changed Original file line number Diff line number Diff line change 1717
1818package org .apache .dolphinscheduler .scheduler .quartz ;
1919
20- import org .apache .commons .lang3 .StringUtils ;
2120import org .apache .dolphinscheduler .common .Constants ;
2221import org .apache .dolphinscheduler .common .enums .CommandType ;
2322import org .apache .dolphinscheduler .common .enums .ReleaseState ;
2726import org .apache .dolphinscheduler .scheduler .quartz .utils .QuartzTaskUtils ;
2827import org .apache .dolphinscheduler .service .process .ProcessService ;
2928
29+ import org .apache .commons .lang3 .StringUtils ;
30+
3031import java .util .Date ;
3132
3233import org .quartz .JobDataMap ;
Original file line number Diff line number Diff line change 3232import static org .apache .dolphinscheduler .plugin .task .api .enums .Direct .IN ;
3333import static org .apache .dolphinscheduler .plugin .task .api .utils .DataQualityConstants .TASK_INSTANCE_ID ;
3434
35- import org .apache .commons .lang3 .StringUtils ;
3635import org .apache .dolphinscheduler .common .Constants ;
3736import org .apache .dolphinscheduler .common .enums .AuthorizationType ;
3837import org .apache .dolphinscheduler .common .enums .CommandType ;
138137import org .apache .dolphinscheduler .spi .enums .ResourceType ;
139138
140139import org .apache .commons .collections .CollectionUtils ;
140+ import org .apache .commons .lang3 .StringUtils ;
141141
142142import java .util .ArrayList ;
143143import java .util .Arrays ;
@@ -416,7 +416,9 @@ public int createCommand(Command command) {
416416 // add command timezone
417417 Schedule schedule = scheduleMapper .queryByProcessDefinitionCode (command .getProcessDefinitionCode ());
418418 if (schedule != null ) {
419- Map <String , String > commandParams = StringUtils .isNotBlank (command .getCommandParam ()) ? JSONUtils .toMap (command .getCommandParam ()) : new HashMap <>();
419+ Map <String , String > commandParams =
420+ StringUtils .isNotBlank (command .getCommandParam ()) ? JSONUtils .toMap (command .getCommandParam ())
421+ : new HashMap <>();
420422 commandParams .put (Constants .SCHEDULE_TIMEZONE , schedule .getTimezoneId ());
421423 command .setCommandParam (JSONUtils .toJsonString (commandParams ));
422424 }
You can’t perform that action at this time.
0 commit comments