|
|
|
@ -32,7 +32,6 @@ import static org.apache.dolphinscheduler.plugin.task.api.enums.DataType.VARCHAR
|
|
|
|
|
import static org.apache.dolphinscheduler.plugin.task.api.enums.Direct.IN; |
|
|
|
|
import static org.apache.dolphinscheduler.plugin.task.api.utils.DataQualityConstants.TASK_INSTANCE_ID; |
|
|
|
|
|
|
|
|
|
import org.apache.commons.lang3.StringUtils; |
|
|
|
|
import org.apache.dolphinscheduler.common.Constants; |
|
|
|
|
import org.apache.dolphinscheduler.common.enums.AuthorizationType; |
|
|
|
|
import org.apache.dolphinscheduler.common.enums.CommandType; |
|
|
|
@ -138,6 +137,7 @@ import org.apache.dolphinscheduler.service.utils.DagHelper;
|
|
|
|
|
import org.apache.dolphinscheduler.spi.enums.ResourceType; |
|
|
|
|
|
|
|
|
|
import org.apache.commons.collections.CollectionUtils; |
|
|
|
|
import org.apache.commons.lang3.StringUtils; |
|
|
|
|
|
|
|
|
|
import java.util.ArrayList; |
|
|
|
|
import java.util.Arrays; |
|
|
|
@ -416,7 +416,9 @@ public class ProcessServiceImpl implements ProcessService {
|
|
|
|
|
// add command timezone
|
|
|
|
|
Schedule schedule = scheduleMapper.queryByProcessDefinitionCode(command.getProcessDefinitionCode()); |
|
|
|
|
if (schedule != null) { |
|
|
|
|
Map<String, String> commandParams = StringUtils.isNotBlank(command.getCommandParam()) ? JSONUtils.toMap(command.getCommandParam()) : new HashMap<>(); |
|
|
|
|
Map<String, String> commandParams = |
|
|
|
|
StringUtils.isNotBlank(command.getCommandParam()) ? JSONUtils.toMap(command.getCommandParam()) |
|
|
|
|
: new HashMap<>(); |
|
|
|
|
commandParams.put(Constants.SCHEDULE_TIMEZONE, schedule.getTimezoneId()); |
|
|
|
|
command.setCommandParam(JSONUtils.toJsonString(commandParams)); |
|
|
|
|
} |
|
|
|
|