diff --git a/src/main/java/com/actiontech/dble/config/helper/GetAndSyncDbInstanceKeyVariables.java b/src/main/java/com/actiontech/dble/config/helper/GetAndSyncDbInstanceKeyVariables.java
index 93f7ff439..07d479c1a 100644
--- a/src/main/java/com/actiontech/dble/config/helper/GetAndSyncDbInstanceKeyVariables.java
+++ b/src/main/java/com/actiontech/dble/config/helper/GetAndSyncDbInstanceKeyVariables.java
@@ -72,7 +72,7 @@ public class GetAndSyncDbInstanceKeyVariables implements Callable<KeyVariables>
                 if (!await) {
                     fail = true;
                     isFinish = true;
-                    LOGGER.warn("test conn timeout，TCP connection may be lost");
+                    LOGGER.warn("test conn timeout,TCP connection may be lost");
                 }
             }
         } catch (InterruptedException e) {
diff --git a/src/main/java/com/actiontech/dble/config/util/ParameterMapping.java b/src/main/java/com/actiontech/dble/config/util/ParameterMapping.java
index 59dd245f0..c6f580656 100644
--- a/src/main/java/com/actiontech/dble/config/util/ParameterMapping.java
+++ b/src/main/java/com/actiontech/dble/config/util/ParameterMapping.java
@@ -194,7 +194,7 @@ public final class ParameterMapping {
                         throw (RuntimeException) targetException;
                     }
                 }
-                // won't happen generally，If it still happens ，maybe throw an exception and stop process  is a good idea.
+                // won't happen generally,If it still happens ,maybe throw an exception and stop process  is a good idea.
                 LOGGER.info("valueofError", t);
                 throw new IllegalStateException(t);
             }
diff --git a/src/main/java/com/actiontech/dble/route/parser/druid/ServerSchemaStatVisitor.java b/src/main/java/com/actiontech/dble/route/parser/druid/ServerSchemaStatVisitor.java
index 05aba765f..a61fdefdd 100644
--- a/src/main/java/com/actiontech/dble/route/parser/druid/ServerSchemaStatVisitor.java
+++ b/src/main/java/com/actiontech/dble/route/parser/druid/ServerSchemaStatVisitor.java
@@ -355,7 +355,7 @@ public class ServerSchemaStatVisitor extends MySqlSchemaStatVisitor {
     public boolean visit(SQLUnaryExpr x) {
         switch (x.getOperator()) {
             case Not:
-            // It doesn't match now it might match in the future，don't delete
+            // It doesn't match now it might match in the future,don't delete
             case NOT:
             case Compl:
                 return false;
diff --git a/src/main/java/com/actiontech/dble/server/status/GeneralLog.java b/src/main/java/com/actiontech/dble/server/status/GeneralLog.java
index bca4b8bc3..982b3acbb 100644
--- a/src/main/java/com/actiontech/dble/server/status/GeneralLog.java
+++ b/src/main/java/com/actiontech/dble/server/status/GeneralLog.java
@@ -26,7 +26,7 @@ public final class GeneralLog {
         try {
             this.generalLogFile = file.getCanonicalPath();
         } catch (IOException e) {
-            LOGGER.warn("Invalid generalLogFile path configuration，exception: {}", e);
+            LOGGER.warn("Invalid generalLogFile path configuration,exception: {}", e);
             this.generalLogFile = file.getAbsolutePath();
         }
         this.generalLogFileSize = SystemConfig.getInstance().getGeneralLogFileSize();
diff --git a/src/main/java/com/actiontech/dble/services/FrontendService.java b/src/main/java/com/actiontech/dble/services/FrontendService.java
index 36af1779e..156e8396c 100644
--- a/src/main/java/com/actiontech/dble/services/FrontendService.java
+++ b/src/main/java/com/actiontech/dble/services/FrontendService.java
@@ -53,9 +53,9 @@ public abstract class FrontendService<T extends UserConfig> extends AbstractServ
     // will non null if is dong task
     private volatile Long doingTaskThread = null;
     private AtomicLong taskId = new AtomicLong(1);
-    // current task index，Will increased when every new task is processed。
+    // current task index,Will increased when every new task is processed。
     private long currentTaskIndex = 0;
-    // consumed task  id，Used to indicate next task id.(this=nextTaskId-1)
+    // consumed task  id,Used to indicate next task id.(this=nextTaskId-1)
     private volatile long consumedTaskId = 0;
     // client capabilities
     private final long clientCapabilities;
diff --git a/src/main/java/com/actiontech/dble/services/manager/response/ReloadConfig.java b/src/main/java/com/actiontech/dble/services/manager/response/ReloadConfig.java
index db3418c97..f6ad1c4e1 100644
--- a/src/main/java/com/actiontech/dble/services/manager/response/ReloadConfig.java
+++ b/src/main/java/com/actiontech/dble/services/manager/response/ReloadConfig.java
@@ -144,7 +144,7 @@ public final class ReloadConfig {
                     }
                     if (!reloadResult) {
                         packetResult.setSuccess(false);
-                        packetResult.setErrorMsg("Reload config failure.The reason is reload interruputed by others,config should be reload");
+                        packetResult.setErrorMsg("Reload Failure.The reason is reload interruputed by others,config should be reload");
                         packetResult.setErrorCode(ErrorCode.ER_RELOAD_INTERRUPUTED);
                         return;
                     }
@@ -199,7 +199,7 @@ public final class ReloadConfig {
         try {
             if (!ReloadManager.startReload(TRIGGER_TYPE_COMMAND, confStatus)) {
                 packetResult.setSuccess(false);
-                packetResult.setErrorMsg("Reload config failure.The reason is reload status error ,other client or cluster may in reload");
+                packetResult.setErrorMsg("Reload Failure.The reason is reload status error ,other client or cluster may in reload");
                 packetResult.setErrorCode(ErrorCode.ER_YES);
                 return;
             }
@@ -215,7 +215,7 @@ public final class ReloadConfig {
                 return;
             } else if (!reloadResult) {
                 packetResult.setSuccess(false);
-                packetResult.setErrorMsg("Reload config failure.The reason is reload interruputed by others,metadata should be reload");
+                packetResult.setErrorMsg("Reload Failure.The reason is reload interruputed by others,metadata should be reload");
                 packetResult.setErrorCode(ErrorCode.ER_RELOAD_INTERRUPUTED);
             }
         } finally {
@@ -226,7 +226,7 @@ public final class ReloadConfig {
 
 
     private static void writeErrorResult(ManagerService c, String errorMsg) {
-        String sb = "Reload config failure.The reason is " + errorMsg;
+        String sb = "Reload Failure.The reason is " + errorMsg;
         LOGGER.warn(sb);
         c.writeErrMessage(ErrorCode.ER_YES, sb);
     }
diff --git a/src/main/java/com/actiontech/dble/singleton/PauseShardingNodeManager.java b/src/main/java/com/actiontech/dble/singleton/PauseShardingNodeManager.java
index 33f59d4f0..fb114775f 100644
--- a/src/main/java/com/actiontech/dble/singleton/PauseShardingNodeManager.java
+++ b/src/main/java/com/actiontech/dble/singleton/PauseShardingNodeManager.java
@@ -71,7 +71,7 @@ public final class PauseShardingNodeManager {
     }
 
     /**
-     * in this implementation, when call this method 'fetchClusterStatus()',the port is already be listened ，but the server has not ready for accept connection yet. So,no FrontConnection will be created, we don't need to call 'waitForSelfPause()' to wait for connection paused;
+     * in this implementation, when call this method 'fetchClusterStatus()',the port is already be listened ,but the server has not ready for accept connection yet. So,no FrontConnection will be created, we don't need to call 'waitForSelfPause()' to wait for connection paused;
      *
      * @throws Exception
      */