This is an automated email from the ASF dual-hosted git repository.
wenjun pushed a change to branch 3.0.0-prepare
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
from ae4c3ab4e1 [Fix] Fix the JSONUtils tool class time zone problem #10282
(#10284)
new 4ceb420873 Fix TaskProcessorFactory#getTaskProcessor get common
processor is not thread safe (#10479)
new 81cadd15d2 Optimize MasterServer, add MasterRPCService (#10371)
new 318a8e3ae0 [Feature][metrics] Add master, worker metrics (#10326)
new 52815975bc Add some warning log in master (#10383)
new 1def1729bc Add lombok
new 9a4c7f876a Fix TaskProcessorFactory#getTaskProcessor get common
processor is not thread safe (#10479)
new 9a59054655 Fix PeerTaskInstancePriorityQueue cannot contains method
use taskInstanceId to check (#10491)
new 90c87f0121 [Fix-10413] Fix Master startup failure the server still
hang (#10500)
new 9a28d32057 Remove the schedule thread in LowerWeightHostManager
(#10310)
new 3ab9ee13fc Optimize master log, use MDC to inject workflow instance id
and task instance id in log (#10516)
new fc1c1f6ad1 add CMDPARAM_COMPLEMENT_DATA_SCHEDULE_DATE_LIST
new c488a9f828 Fix compile error
new db31deb54f [Bug] [Master] Worker failover will cause task cannot be
failover (#10631)
new 4b224ae2e5 Validate master/worker config (#10649)
new 6c83967ebe [Improvement-10617] Add comment in slot check (#10618)
new 3b923e5933 [Fix-10666] Workflow submit failed will still in memory and
never retry (#10667)
new 7500e99682 [Fix-10785] Fix state event handle error will not retry
(#10786)
new 04c47034d4 Add task prepare metrics
new da03ef32e9 Fix compile error
new 4fc9bce444 [Fix-10785] Fix state event handle error will not retry
(#10786)
new 71edaf41a2 [Fix-10842] Fix master/worker failover will cause status
incorrect (#10839)
new b259deb196 [Fix-10854] Fix database restart may lost task instance
status (#10866)
new 9ee20cffef [Fix-10827] Fix network error cause worker cannot send
message to master (#10886)
new 527ee472fb Catch exception when check state in StateWheelExecuteThread
(#10908)
new 812d7a8f26 Fix taskInstance's host is not worker nettyServer address
(#10926)
new 44ddb6908e Fix kill yarn job error when failover caused by doesn't set
ProcessDefinition (#10948)
new 17f0be5bfb Kill task when we do master failover to avoid task lost
(#10997)
new f3250bf5fa Fix worker cannot shutdown due to resource close failed or
heart beat check failed (#10979)
new 6df8593add Return status
The 29 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
docs/docs/en/guide/metrics/metrics.md | 154 ++
docs/img/metrics/metrics-datasource.png | Bin 0 -> 336581 bytes
docs/img/metrics/metrics-master.png | Bin 0 -> 467778 bytes
docs/img/metrics/metrics-worker.png | Bin 0 -> 403432 bytes
.../apache/dolphinscheduler/alert/AlertServer.java | 23 +-
.../src/main/resources/banner.txt | 2 +-
.../api/service/impl/ExecutorServiceImpl.java | 12 +-
.../src/main/resources/application.yaml | 3 +
dolphinscheduler-api/src/main/resources/banner.txt | 2 +-
.../apache/dolphinscheduler/common/Constants.java | 52 +-
.../dolphinscheduler/common/enums/StateEvent.java | 123 -
.../common/enums/StateEventType.java | 2 +-
.../enums/{Event.java => TaskEventType.java} | 2 +-
.../apache/dolphinscheduler/common/graph/DAG.java | 11 +
.../dolphinscheduler/common/model/TaskNode.java | 2 +-
.../common/storage/StorageOperate.java | 32 +-
.../thread/{Stopper.java => BaseDaemonThread.java} | 22 +-
.../dolphinscheduler/common/thread/Stopper.java | 34 +-
.../common/thread/ThreadUtils.java | 26 +-
.../dolphinscheduler/common/utils/FileUtils.java | 29 +-
.../dolphinscheduler/common/utils/LoggerUtils.java | 34 +-
.../dolphinscheduler/common/utils/OSUtils.java | 21 +-
.../dao/entity/ProcessInstance.java | 12 +-
.../dao/utils/TaskInstanceUtils.java | 79 +
.../dao/utils/TaskInstanceUtilsTest.java | 40 +-
.../server/master/MasterServer.java | 113 +-
.../cache/ProcessInstanceExecCacheManager.java | 10 +-
.../impl/ProcessInstanceExecCacheManagerImpl.java | 23 +-
.../server/master/config/MasterConfig.java | 249 +-
.../master/consumer/TaskPriorityQueueConsumer.java | 85 +-
.../master/dispatch/context/ExecutionContext.java | 45 +-
.../dispatch/executor/NettyExecutorManager.java | 5 +-
.../dispatch/host/LowerWeightHostManager.java | 136 +-
.../master/dispatch/host/assign/Selector.java | 2 +-
.../assign/Selector.java => event/StateEvent.java} | 35 +-
.../StateEventHandleError.java} | 23 +-
.../StateEventHandleException.java} | 22 +-
.../Selector.java => event/StateEventHandler.java} | 24 +-
.../master/event/StateEventHandlerManager.java | 37 +-
.../server/master/event/TaskDelayEventHandler.java | 120 +
.../master/event/TaskDispatchEventHandler.java | 88 +
.../TaskEventHandleError.java} | 21 +-
.../TaskEventHandleException.java} | 21 +-
.../Selector.java => event/TaskEventHandler.java} | 22 +-
.../event/TaskRejectByWorkerEventHandler.java | 84 +
.../master/event/TaskResultEventHandler.java | 125 +
.../master/event/TaskRetryStateEventHandler.java | 47 +
.../master/event/TaskRunningEventHandler.java | 118 +
.../server/master/event/TaskStateEventHandler.java | 115 +
.../master/event/TaskTimeoutStateEventHandler.java | 64 +
.../event/TaskWaitTaskGroupStateHandler.java | 28 +-
.../event/WorkflowBlockStateEventHandler.java | 60 +
.../server/master/event/WorkflowEvent.java | 19 +-
.../WorkflowEventHandleError.java} | 21 +-
.../WorkflowEventHandleException.java} | 21 +-
.../WorkflowEventHandler.java} | 21 +-
.../server/master/event/WorkflowEventQueue.java | 48 +
.../server/master/event/WorkflowEventType.java | 11 +-
.../master/event/WorkflowStartEventHandler.java | 86 +
.../master/event/WorkflowStateEventHandler.java | 94 +
.../event/WorkflowTimeoutStateEventHandler.java | 39 +-
.../MasterException.java} | 21 +-
.../server/master/metrics/MasterServerMetrics.java | 53 +
.../master/metrics/ProcessInstanceMetrics.java | 126 +
.../server/master/metrics/TaskMetrics.java | 137 +
.../master/processor/StateEventProcessor.java | 18 +-
.../master/processor/TaskEventProcessor.java | 16 +-
.../processor/TaskExecuteResponseProcessor.java | 23 +-
.../processor/TaskExecuteRunningProcessor.java | 8 +-
.../processor/TaskKillResponseProcessor.java | 3 +-
.../master/processor/TaskRecallProcessor.java | 0
.../processor/queue/StateEventResponseService.java | 44 +-
.../server/master/processor/queue/TaskEvent.java | 126 +-
.../master/processor/queue/TaskEventService.java | 30 +-
.../processor/queue/TaskExecuteRunnable.java | 104 +
.../master/processor/queue/TaskExecuteThread.java | 224 --
.../processor/queue/TaskExecuteThreadPool.java | 72 +-
.../registry/MasterConnectionStateListener.java | 62 +
.../master/registry/MasterRegistryClient.java | 96 +-
.../registry/MasterRegistryDataListener.java | 1 +
.../server/master/registry/ServerNodeManager.java | 22 +
.../WorkerInfoChangeListener.java} | 20 +-
.../MasterRPCServer.java} | 131 +-
.../server/master/runner/EventExecuteService.java | 28 +-
.../master/runner/FailoverExecuteThread.java | 24 +-
.../master/runner/MasterSchedulerBootstrap.java | 257 ++
.../master/runner/MasterSchedulerService.java | 253 --
.../master/runner/StateWheelExecuteThread.java | 313 ++-
.../server/master/runner/WorkflowEventLooper.java | 108 +
...uteThread.java => WorkflowExecuteRunnable.java} | 1065 ++++----
.../master/runner/WorkflowExecuteThreadPool.java | 68 +-
.../WorkflowSubmitStatue.java} | 26 +-
.../master/runner/task/BaseTaskProcessor.java | 26 +-
.../master/runner/task/CommonTaskProcessor.java | 11 +-
.../server/master/runner/task/TaskInstanceKey.java | 62 +-
.../master/runner/task/TaskProcessorFactory.java | 33 +-
.../server/master/service/FailoverService.java | 343 +--
.../master/service/MasterFailoverService.java | 281 +++
.../master/service/WorkerFailoverService.java | 267 ++
.../src/main/resources/application.yaml | 19 +-
.../src/main/resources/banner.txt | 2 +-
.../src/main/resources/logback-spring.xml | 4 +-
.../server/master/BlockingTaskTest.java | 5 +-
.../server/master/ConditionsTaskTest.java | 3 +-
.../server/master/DependentTaskTest.java | 3 +-
.../server/master/SubProcessTaskTest.java | 3 +-
.../server/master/SwitchTaskTest.java | 3 +-
.../ProcessInstanceExecCacheManagerImplTest.java | 14 +-
.../master/dispatch/ExecutionContextTestUtils.java | 19 +-
.../master/dispatch/ExecutorDispatcherTest.java | 6 +-
.../executor/NettyExecutorManagerTest.java | 29 +-
.../master/processor/TaskAckProcessorTest.java | 20 +-
.../processor/queue/TaskResponseServiceTest.java | 53 +-
.../master/registry/MasterRegistryClientTest.java | 7 -
.../master/registry/ServerNodeManagerTest.java | 60 -
.../WorkflowExecuteRunnableTest.java} | 34 +-
.../runner/task/TaskProcessorFactoryTest.java | 4 +-
.../server/master/service/FailoverServiceTest.java | 45 +-
.../dolphinscheduler/meter/MeterConfiguration.java | 12 +
.../resources/grafana-demo/docker-compose.yaml | 5 +-
.../resources/grafana/DolphinSchedulerMaster.json | 2607 ++++++++++++++++----
.../resources/grafana/DolphinSchedulerWorker.json | 1598 ++++++++++++
.../remote/NettyRemotingClient.java | 4 +-
.../remote/command/BaseCommand.java | 57 +
.../dolphinscheduler/remote/command/Command.java | 3 +
.../remote/command/CommandHeader.java | 47 +-
.../remote/command/CommandType.java | 26 +-
.../remote/command/HostUpdateCommand.java | 3 -
.../remote/command/StateEventResponseCommand.java | 2 +-
...equestCommand.java => TaskDispatchCommand.java} | 50 +-
...eAckCommand.java => TaskExecuteAckCommand.java} | 48 +-
.../remote/command/TaskExecuteResponseCommand.java | 212 --
...kCommand.java => TaskExecuteResultCommand.java} | 97 +-
...mand.java => TaskExecuteRunningAckMessage.java} | 6 +-
.../remote/command/TaskExecuteRunningCommand.java | 101 +-
.../remote/command/TaskKillRequestCommand.java | 22 +-
...questCommand.java => TaskRejectAckCommand.java} | 42 +-
.../remote/command/TaskRejectCommand.java | 0
.../remote/processor/NettyRemoteChannel.java | 7 +-
.../processor/StateEventCallbackService.java | 31 +-
.../remote/utils/ChannelUtils.java | 12 +-
.../apache/dolphinscheduler/remote/utils/Host.java | 5 +-
.../server/registry/HeartBeatTask.java | 21 +-
.../server/utils/ProcessUtils.java | 7 +-
.../service/alert/AlertClientService.java | 21 +-
.../service/bean/SpringApplicationContext.java | 3 +-
.../service/process/ProcessService.java | 13 +-
.../service/process/ProcessServiceImpl.java | 84 +-
.../queue/PeerTaskInstancePriorityQueue.java | 56 +-
.../service/queue/TaskPriority.java | 41 +-
.../service/queue/TaskPriorityQueue.java | 2 +-
.../service/queue/TaskPriorityQueueImpl.java | 12 +-
.../service/registry/RegistryClient.java | 3 +-
.../service/task/TaskPluginManager.java | 5 +-
.../service/process/ProcessServiceTest.java | 61 +-
.../queue/PeerTaskInstancePriorityQueueTest.java | 15 +-
.../apache/dolphinscheduler/StandaloneServer.java | 32 +-
.../src/main/resources/application.yaml | 26 +-
.../src/main/resources/banner.txt | 2 +-
.../src/main/resources/logback-spring.xml | 4 +-
.../plugin/task/api/ProcessUtils.java | 15 +-
.../plugin/task/api/TaskExecutionContext.java | 383 +--
.../plugin/task/api/TaskPluginException.java | 13 +-
.../plugin/task/api/enums/ExecutionStatus.java | 23 +
.../plugin/task/shell/ShellTask.java | 7 +-
.../server/worker/WorkerServer.java | 146 +-
.../server/worker/cache/ResponseCache.java | 98 -
.../server/worker/config/WorkerConfig.java | 154 +-
.../server/worker/message/MessageRetryRunner.java | 139 ++
.../server/worker/message/MessageSender.java | 43 +
.../message/TaskExecuteResultMessageSender.java | 70 +
.../message/TaskExecuteRunningMessageSender.java | 67 +
.../worker/message/TaskRejectMessageSender.java | 59 +
.../server/worker/metrics/TaskMetrics.java | 58 +
.../server/worker/metrics/WorkerServerMetrics.java | 55 +
.../worker/processor/HostUpdateProcessor.java | 13 +-
.../worker/processor/TaskCallbackService.java | 260 --
.../worker/processor/TaskDispatchProcessor.java | 212 ++
.../worker/processor/TaskExecuteProcessor.java | 186 --
.../processor/TaskExecuteResponseAckProcessor.java | 65 -
.../processor/TaskExecuteResultAckProcessor.java | 83 +
.../processor/TaskExecuteRunningAckProcessor.java | 28 +-
.../server/worker/processor/TaskKillProcessor.java | 49 +-
.../worker/processor/TaskRejectAckProcessor.java | 0
.../worker/registry/WorkerRegistryClient.java | 38 +-
.../server/worker/rpc/WorkerMessageSender.java | 92 +
.../server/worker/rpc/WorkerRpcClient.java | 70 +
.../server/worker/rpc/WorkerRpcServer.java | 97 +
.../worker/runner/RetryReportTaskStatusThread.java | 90 -
.../server/worker/runner/TaskExecuteThread.java | 126 +-
.../server/worker/runner/WorkerExecService.java | 9 +-
.../server/worker/runner/WorkerManagerThread.java | 39 +-
.../src/main/resources/application.yaml | 9 +-
.../src/main/resources/banner.txt | 2 +-
.../src/main/resources/logback-spring.xml | 4 +-
...sorTest.java => TaskDispatchProcessorTest.java} | 100 +-
.../worker/registry/WorkerRegistryClientTest.java | 13 +-
.../worker/runner/TaskExecuteThreadTest.java | 35 +-
pom.xml | 7 +
199 files changed, 10414 insertions(+), 5582 deletions(-)
create mode 100644 docs/docs/en/guide/metrics/metrics.md
create mode 100644 docs/img/metrics/metrics-datasource.png
create mode 100644 docs/img/metrics/metrics-master.png
create mode 100644 docs/img/metrics/metrics-worker.png
delete mode 100644
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/StateEvent.java
copy
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/{Event.java
=> TaskEventType.java} (97%)
copy
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/thread/{Stopper.java
=> BaseDaemonThread.java} (65%)
create mode 100644
dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/utils/TaskInstanceUtils.java
rename
dolphinscheduler-master/src/test/java/org/apache/dolphinscheduler/server/master/dispatch/host/RefreshResourceTaskTest.java
=>
dolphinscheduler-dao/src/test/java/org/apache/dolphinscheduler/dao/utils/TaskInstanceUtilsTest.java
(50%)
copy
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/{dispatch/host/assign/Selector.java
=> event/StateEvent.java} (56%)
copy
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/{dispatch/host/assign/Selector.java
=> event/StateEventHandleError.java} (63%)
copy
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/{dispatch/host/assign/Selector.java
=> event/StateEventHandleException.java} (65%)
copy
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/{dispatch/host/assign/Selector.java
=> event/StateEventHandler.java} (51%)
copy
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/StateEventType.java
=>
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/StateEventHandlerManager.java
(52%)
create mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/TaskDelayEventHandler.java
create mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/TaskDispatchEventHandler.java
copy
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/{dispatch/host/assign/Selector.java
=> event/TaskEventHandleError.java} (72%)
copy
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/{dispatch/host/assign/Selector.java
=> event/TaskEventHandleException.java} (71%)
copy
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/{dispatch/host/assign/Selector.java
=> event/TaskEventHandler.java} (58%)
create mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/TaskRejectByWorkerEventHandler.java
create mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/TaskResultEventHandler.java
create mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/TaskRetryStateEventHandler.java
create mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/TaskRunningEventHandler.java
create mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/TaskStateEventHandler.java
create mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/TaskTimeoutStateEventHandler.java
copy
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/thread/Stopper.java
=>
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/TaskWaitTaskGroupStateHandler.java
(55%)
create mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/WorkflowBlockStateEventHandler.java
copy
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/Event.java
=>
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/WorkflowEvent.java
(75%)
copy
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/{dispatch/host/assign/Selector.java
=> event/WorkflowEventHandleError.java} (71%)
copy
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/{dispatch/host/assign/Selector.java
=> event/WorkflowEventHandleException.java} (71%)
copy
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/{dispatch/host/assign/Selector.java
=> event/WorkflowEventHandler.java} (60%)
create mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/WorkflowEventQueue.java
copy
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/Event.java
=>
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/WorkflowEventType.java
(87%)
create mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/WorkflowStartEventHandler.java
create mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/WorkflowStateEventHandler.java
copy
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/StateEventType.java
=>
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/event/WorkflowTimeoutStateEventHandler.java
(50%)
copy
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/{dispatch/host/assign/Selector.java
=> exception/MasterException.java} (73%)
create mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/metrics/MasterServerMetrics.java
create mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/metrics/ProcessInstanceMetrics.java
create mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/metrics/TaskMetrics.java
copy dolphinscheduler-python/pydolphinscheduler/docs/source/_static/.gitkeep
=>
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/processor/TaskRecallProcessor.java
(100%)
create mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/processor/queue/TaskExecuteRunnable.java
delete mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/processor/queue/TaskExecuteThread.java
create mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/registry/MasterConnectionStateListener.java
copy
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/{dispatch/host/assign/Selector.java
=> registry/WorkerInfoChangeListener.java} (58%)
copy
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/{MasterServer.java
=> rpc/MasterRPCServer.java} (50%)
create mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterSchedulerBootstrap.java
delete mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterSchedulerService.java
create mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowEventLooper.java
rename
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/{WorkflowExecuteThread.java
=> WorkflowExecuteRunnable.java} (66%)
copy
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/{dispatch/host/assign/Selector.java
=> runner/WorkflowSubmitStatue.java} (72%)
create mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/service/MasterFailoverService.java
create mode 100644
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/service/WorkerFailoverService.java
delete mode 100644
dolphinscheduler-master/src/test/java/org/apache/dolphinscheduler/server/master/registry/ServerNodeManagerTest.java
rename
dolphinscheduler-master/src/test/java/org/apache/dolphinscheduler/server/master/{WorkflowExecuteThreadTest.java
=> runner/WorkflowExecuteRunnableTest.java} (90%)
create mode 100644
dolphinscheduler-meter/src/main/resources/grafana/DolphinSchedulerWorker.json
create mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/command/BaseCommand.java
rename
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/command/{TaskExecuteRequestCommand.java
=> TaskDispatchCommand.java} (57%)
copy
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/command/{TaskExecuteResponseAckCommand.java
=> TaskExecuteAckCommand.java} (62%)
delete mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/command/TaskExecuteResponseCommand.java
rename
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/command/{TaskExecuteResponseAckCommand.java
=> TaskExecuteResultCommand.java} (51%)
rename
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/command/{TaskExecuteRunningAckCommand.java
=> TaskExecuteRunningAckMessage.java} (92%)
copy
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/command/{TaskKillRequestCommand.java
=> TaskRejectAckCommand.java} (62%)
copy dolphinscheduler-python/pydolphinscheduler/docs/source/_static/.gitkeep
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/command/TaskRejectCommand.java
(100%)
rename
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/Event.java
=>
dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/TaskPluginException.java
(80%)
create mode 100644
dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/message/MessageRetryRunner.java
create mode 100644
dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/message/MessageSender.java
create mode 100644
dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/message/TaskExecuteResultMessageSender.java
create mode 100644
dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/message/TaskExecuteRunningMessageSender.java
create mode 100644
dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/message/TaskRejectMessageSender.java
create mode 100644
dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/metrics/TaskMetrics.java
create mode 100644
dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/metrics/WorkerServerMetrics.java
create mode 100644
dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/processor/TaskDispatchProcessor.java
delete mode 100644
dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/processor/TaskExecuteProcessor.java
delete mode 100644
dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/processor/TaskExecuteResponseAckProcessor.java
create mode 100644
dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/processor/TaskExecuteResultAckProcessor.java
copy dolphinscheduler-python/pydolphinscheduler/docs/source/_static/.gitkeep
=>
dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/processor/TaskRejectAckProcessor.java
(100%)
create mode 100644
dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/rpc/WorkerMessageSender.java
create mode 100644
dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/rpc/WorkerRpcClient.java
create mode 100644
dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/rpc/WorkerRpcServer.java
rename
dolphinscheduler-worker/src/test/java/org/apache/dolphinscheduler/server/worker/processor/{TaskExecuteProcessorTest.java
=> TaskDispatchProcessorTest.java} (58%)
