[dolphinscheduler] branch dev updated: fix master server task execute processor register. (#6162)

[kirs]

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

kirs 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 f75b5be  fix master server task execute processor register. (#6162)
f75b5be is described below

commit f75b5be28f675dd1e99d20d2e94b6f851cd29054
Author: Kerwin <37063904+zhuangch...@users.noreply.github.com>
AuthorDate: Fri Sep 10 16:56:57 2021 +0800

    fix master server task execute processor register. (#6162)
---
 .../java/org/apache/dolphinscheduler/server/master/MasterServer.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/MasterServer.java
 
b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/MasterServer.java
index 6c17cf1..7b2a1cd 100644
--- 
a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/MasterServer.java
+++ 
b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/MasterServer.java
@@ -127,8 +127,8 @@ public class MasterServer implements IStoppable {
         taskResponseProcessor.init(processInstanceExecMaps);
         StateEventProcessor stateEventProcessor = new StateEventProcessor();
         stateEventProcessor.init(processInstanceExecMaps);
-        
this.nettyRemotingServer.registerProcessor(CommandType.TASK_EXECUTE_RESPONSE, 
ackProcessor);
-        
this.nettyRemotingServer.registerProcessor(CommandType.TASK_EXECUTE_ACK, 
taskResponseProcessor);
+        
this.nettyRemotingServer.registerProcessor(CommandType.TASK_EXECUTE_RESPONSE, 
taskResponseProcessor);
+        
this.nettyRemotingServer.registerProcessor(CommandType.TASK_EXECUTE_ACK, 
ackProcessor);
         
this.nettyRemotingServer.registerProcessor(CommandType.TASK_KILL_RESPONSE, new 
TaskKillResponseProcessor());
         
this.nettyRemotingServer.registerProcessor(CommandType.STATE_EVENT_REQUEST, 
stateEventProcessor);
         this.nettyRemotingServer.start();