diff --git a/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/codec/NettyDecoder.java b/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/codec/NettyDecoder.java
index 3856ecbc4d..3328dd70b7 100644
--- a/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/codec/NettyDecoder.java
+++ b/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/codec/NettyDecoder.java
@@ -17,7 +17,6 @@
 
 package org.apache.dolphinscheduler.rpc.codec;
 
-import org.apache.dolphinscheduler.rpc.serializer.ProtoStuffUtils;
 import org.apache.dolphinscheduler.rpc.serializer.RpcSerializer;
 import org.apache.dolphinscheduler.rpc.serializer.Serializer;
 
@@ -52,10 +51,10 @@ public class NettyDecoder extends ByteToMessageDecoder {
             byteBuf.resetReaderIndex();
         }
 
-        byte serializerType=1;
+        byte serializerType = 1;
         byte[] data = new byte[dataLength];
         byteBuf.readBytes(data);
-        Serializer serializer=RpcSerializer.getSerializerByType(serializerType);
+        Serializer serializer = RpcSerializer.getSerializerByType(serializerType);
         Object obj = serializer.deserialize(data, genericClass);
         list.add(obj);
     }
diff --git a/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/config/ServiceBean.java b/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/config/ServiceBean.java
index 507cacb1d9..cba4254e4e 100644
--- a/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/config/ServiceBean.java
+++ b/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/config/ServiceBean.java
@@ -46,7 +46,7 @@ public class ServiceBean {
 
     private static synchronized void init() {
         // todo config
-        if(initialized.get()){
+        if (initialized.get()) {
             return;
         }
         Reflections f = new Reflections("org/apache/dolphinscheduler/");
diff --git a/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/protocol/MessageHeader.java b/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/protocol/MessageHeader.java
index f6d091855d..4d1168aa66 100644
--- a/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/protocol/MessageHeader.java
+++ b/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/protocol/MessageHeader.java
@@ -19,15 +19,15 @@ package org.apache.dolphinscheduler.rpc.protocol;
 
 public class MessageHeader {
 
-    private byte magic=(byte) 0xbabe;
+    private byte magic = (byte) 0xbabe;
 
     /**
-     *  context length
+     * context length
      */
     private int contextLength;
 
     /**
-     *  context
+     * context
      */
     private byte[] context;
 
@@ -40,7 +40,6 @@ public class MessageHeader {
 
     private byte serialization;
 
-
     public int getContextLength() {
         return contextLength;
     }
diff --git a/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/protocol/RpcProtocol.java b/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/protocol/RpcProtocol.java
index a217ca3aec..d7023f1c01 100644
--- a/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/protocol/RpcProtocol.java
+++ b/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/protocol/RpcProtocol.java
@@ -17,7 +17,7 @@
 
 package org.apache.dolphinscheduler.rpc.protocol;
 
-public class RpcProtocol<T>{
+public class RpcProtocol<T> {
 
     private MessageHeader msgHeader;