This is an automated email from the ASF dual-hosted git repository.
wenjun pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
from 21ca8ddf03 [fix-13734] Fix taskExecuteType field of task definition
was not set correctly (#13735)
add d1b6e6f02c Take over task instance in master failover (#13798)
No new revisions were added by this update.
Summary of changes:
.../builder/TaskExecutionContextBuilder.java | 7 ++
.../processor/HostUpdateResponseProcessor.java | 42 -------
.../server/master/rpc/MasterRpcClient.java | 22 ++--
.../master/runner/MasterSchedulerBootstrap.java | 6 +-
.../master/runner/StreamTaskExecuteRunnable.java | 1 +
.../master/runner/WorkflowExecuteRunnable.java | 97 +++++++++-----
.../master/runner/task/BaseTaskProcessor.java | 1 +
.../master/service/MasterFailoverService.java | 140 ++-------------------
.../master/service/WorkerFailoverService.java | 3 +-
.../master/dispatch/ExecutionContextTestUtils.java | 1 +
.../master/runner/WorkflowExecuteRunnableTest.java | 6 +-
.../server/master/service/FailoverServiceTest.java | 21 +---
.../remote/command/CommandType.java | 11 +-
.../remote/command/HostUpdateCommand.java | 49 --------
.../remote/command/HostUpdateResponseCommand.java | 83 ------------
.../WorkflowHostChangeRequest.java} | 18 ++-
.../WorkflowHostChangeResponse.java} | 39 +++---
.../service/process/ProcessServiceImpl.java | 10 +-
.../plugin/task/api/TaskExecutionContext.java | 2 +
.../task/api/TaskExecutionContextCacheManager.java | 2 +-
.../server/worker/log/TaskInstanceLogHeader.java | 61 ++++++---
.../server/worker/message/MessageSender.java | 2 +-
.../message/TaskExecuteResultMessageSender.java | 6 +-
.../message/TaskExecuteRunningMessageSender.java | 6 +-
.../worker/message/TaskRejectMessageSender.java | 5 +-
.../worker/message/TaskUpdatePidMessageSender.java | 5 +-
.../worker/processor/HostUpdateProcessor.java | 58 ---------
.../worker/processor/TaskDispatchProcessor.java | 7 +-
.../processor/WorkflowHostChangeProcessor.java | 91 ++++++++++++++
.../server/worker/rpc/WorkerMessageSender.java | 9 +-
.../server/worker/rpc/WorkerRpcServer.java | 7 +-
.../DefaultWorkerDelayTaskExecuteRunnable.java | 2 -
...faultWorkerDelayTaskExecuteRunnableFactory.java | 3 -
.../server/worker/runner/TaskCallbackImpl.java | 10 +-
.../runner/WorkerDelayTaskExecuteRunnable.java | 2 -
.../WorkerDelayTaskExecuteRunnableFactory.java | 3 -
.../worker/runner/WorkerTaskExecuteRunnable.java | 23 ++--
.../WorkerTaskExecuteRunnableFactoryBuilder.java | 2 -
.../processor/TaskDispatchProcessorTest.java | 2 +-
.../DefaultWorkerDelayTaskExecuteRunnableTest.java | 2 -
40 files changed, 317 insertions(+), 550 deletions(-)
delete mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/processor/HostUpdateResponseProcessor.java
copy
dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/rpc/ApiRpcClient.java
=>
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/rpc/MasterRpcClient.java
(64%)
delete mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/command/HostUpdateCommand.java
delete mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/command/HostUpdateResponseCommand.java
copy
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/command/{log/ViewLogRequestCommand.java
=> task/WorkflowHostChangeRequest.java} (83%)
copy
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/command/{log/GetLogBytesResponseCommand.java
=> task/WorkflowHostChangeResponse.java} (68%)
delete mode 100644
dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/processor/HostUpdateProcessor.java
create mode 100644
dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/processor/WorkflowHostChangeProcessor.java
