in dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/dto/task/TaskUpdateRequest.java [111:175]
public TaskDefinition mergeIntoTaskDefinition(TaskDefinition taskDefinition) {
TaskDefinition taskDefinitionDeepCopy = (TaskDefinition) BeanUtils.cloneBean(taskDefinition);
assert taskDefinitionDeepCopy != null;
if (this.name != null) {
taskDefinitionDeepCopy.setName(this.name);
}
if (this.description != null) {
taskDefinitionDeepCopy.setDescription(this.description);
}
if (this.taskType != null) {
taskDefinitionDeepCopy.setTaskType(this.taskType);
}
if (this.taskParams != null) {
taskDefinitionDeepCopy.setTaskParams(this.taskParams);
}
if (this.flag != null) {
taskDefinitionDeepCopy.setFlag(Flag.valueOf(this.flag));
}
if (this.taskPriority != null) {
taskDefinitionDeepCopy.setTaskPriority(Priority.valueOf(this.taskPriority));
}
if (this.workerGroup != null) {
taskDefinitionDeepCopy.setWorkerGroup(this.workerGroup);
}
if (this.environmentCode != 0L) {
taskDefinitionDeepCopy.setEnvironmentCode(this.environmentCode);
}
if (this.failRetryTimes != 0) {
taskDefinitionDeepCopy.setFailRetryTimes(this.failRetryTimes);
}
if (this.failRetryInterval != 0) {
taskDefinitionDeepCopy.setFailRetryInterval(this.failRetryInterval);
}
if (this.timeout != 0) {
taskDefinitionDeepCopy.setTimeout(this.timeout);
}
if (this.timeoutFlag != null) {
taskDefinitionDeepCopy.setTimeoutFlag(TimeoutFlag.valueOf(this.timeoutFlag));
}
if (this.timeoutNotifyStrategy != null) {
taskDefinitionDeepCopy.setTimeoutNotifyStrategy(TaskTimeoutStrategy.valueOf(this.timeoutNotifyStrategy));
}
if (this.resourceIds != null) {
taskDefinitionDeepCopy.setResourceIds(this.resourceIds);
}
if (this.taskGroupId != 0) {
taskDefinitionDeepCopy.setTaskGroupId(this.taskGroupId);
}
if (this.taskGroupPriority != 0) {
taskDefinitionDeepCopy.setTaskGroupPriority(this.taskGroupPriority);
}
if (this.cpuQuota != null) {
taskDefinitionDeepCopy.setCpuQuota(this.cpuQuota);
}
if (this.memoryMax != null) {
taskDefinitionDeepCopy.setMemoryMax(this.memoryMax);
}
if (!taskDefinition.equals(taskDefinitionDeepCopy)) {
int version = taskDefinitionDeepCopy.getVersion() + 1;
taskDefinitionDeepCopy.setVersion(version);
taskDefinitionDeepCopy.setUpdateTime(new Date());
}
return taskDefinitionDeepCopy;
}