diff --git a/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/NettyRemotingServer.java b/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/NettyRemotingServer.java
index dbeb318f2d80b4efac373b2933906a63b66a4a65..080c586d0060c64e28ce400b6b0c52f01de89081 100644
--- a/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/NettyRemotingServer.java
+++ b/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/NettyRemotingServer.java
@@ -208,9 +208,7 @@ public class NettyRemotingServer {
                 if(workGroup != null){
                     this.workGroup.shutdownGracefully();
                 }
-                if(defaultExecutor != null){
-                    defaultExecutor.shutdown();
-                }
+                defaultExecutor.shutdown();
             } catch (Exception ex) {
                 logger.error("netty server close exception", ex);
             }