Browse Source

[BUG][TaskExecuteProcessor]setTaskCache is first preTaskCache

pull/3/MERGE
wuxiaofei 4 years ago
parent
commit
757c116b24
  1. 4
      dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/processor/TaskExecuteProcessor.java

4
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/processor/TaskExecuteProcessor.java

@ -95,7 +95,9 @@ public class TaskExecuteProcessor implements NettyRequestProcessor {
* @param taskExecutionContext task * @param taskExecutionContext task
*/ */
private void setTaskCache(TaskExecutionContext taskExecutionContext) { private void setTaskCache(TaskExecutionContext taskExecutionContext) {
taskExecutionContextCacheManager.cacheTaskExecutionContext(taskExecutionContext); TaskExecutionContext preTaskCache = new TaskExecutionContext();
preTaskCache.setTaskInstanceId(taskExecutionContext.getTaskInstanceId());
taskExecutionContextCacheManager.cacheTaskExecutionContext(preTaskCache);
} }
public TaskExecuteProcessor(AlertClientService alertClientService) { public TaskExecuteProcessor(AlertClientService alertClientService) {

Loading…
Cancel
Save