[dolphinscheduler] branch dev updated: Update TaskInstanceCacheManagerImpl.java (#5656)

[kerwin]

This is an automated email from the ASF dual-hosted git repository.

kerwin pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new 0d7c32a  Update TaskInstanceCacheManagerImpl.java (#5656)
0d7c32a is described below

commit 0d7c32a1e829202d8359f112383b1b56eec6653d
Author: justoy <r...@live.com>
AuthorDate: Thu Jun 17 18:45:34 2021 +0800

    Update TaskInstanceCacheManagerImpl.java (#5656)
---
 .../server/master/cache/impl/TaskInstanceCacheManagerImpl.java           | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/cache/impl/TaskInstanceCacheManagerImpl.java
 
b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/cache/impl/TaskInstanceCacheManagerImpl.java
index 43632ae..0df38c9 100644
--- 
a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/cache/impl/TaskInstanceCacheManagerImpl.java
+++ 
b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/cache/impl/TaskInstanceCacheManagerImpl.java
@@ -110,6 +110,7 @@ public class TaskInstanceCacheManagerImpl implements 
TaskInstanceCacheManager {
     @Override
     public void cacheTaskInstance(TaskExecuteAckCommand taskAckCommand) {
         TaskInstance taskInstance = new TaskInstance();
+        taskInstance.setId(taskAckCommand.getTaskInstanceId());
         taskInstance.setState(ExecutionStatus.of(taskAckCommand.getStatus()));
         taskInstance.setStartTime(taskAckCommand.getStartTime());
         taskInstance.setHost(taskAckCommand.getHost());