Browse Source

Update TaskInstanceCacheManagerImpl.java (#5656)

2.0.7-release
justoy 3 years ago committed by GitHub
parent
commit
0d7c32a1e8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 1
      dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/cache/impl/TaskInstanceCacheManagerImpl.java

1
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/cache/impl/TaskInstanceCacheManagerImpl.java vendored

@ -110,6 +110,7 @@ public class TaskInstanceCacheManagerImpl implements TaskInstanceCacheManager {
@Override @Override
public void cacheTaskInstance(TaskExecuteAckCommand taskAckCommand) { public void cacheTaskInstance(TaskExecuteAckCommand taskAckCommand) {
TaskInstance taskInstance = new TaskInstance(); TaskInstance taskInstance = new TaskInstance();
taskInstance.setId(taskAckCommand.getTaskInstanceId());
taskInstance.setState(ExecutionStatus.of(taskAckCommand.getStatus())); taskInstance.setState(ExecutionStatus.of(taskAckCommand.getStatus()));
taskInstance.setStartTime(taskAckCommand.getStartTime()); taskInstance.setStartTime(taskAckCommand.getStartTime());
taskInstance.setHost(taskAckCommand.getHost()); taskInstance.setHost(taskAckCommand.getHost());

Loading…
Cancel
Save