change PException

XiaoMi · Oct 17, 2019 · 2682979 · 2682979
1 parent 7c5a755
commit 2682979
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/main/java/com/xiaomi/infra/pegasus/client/PegasusTable.java b/src/main/java/com/xiaomi/infra/pegasus/client/PegasusTable.java
@@ -1649,7 +1649,7 @@ private void handleReplicaException(
     gpid gPid = op.get_gpid();
     ReplicaConfiguration replicaConfiguration =
         ((TableHandler) table).getReplicaConfig(gPid.get_pidx());
-    String replicaServer = null;
+    String replicaServer;
     try {
       replicaServer =
           replicaConfiguration.primary.get_ip() + ":" + replicaConfiguration.primary.get_port();
@@ -1666,13 +1666,13 @@ private void handleReplicaException(
             + op.name()
             + ",replicaServer="
             + replicaServer
-            + ",gPid=("
+            + ",gpid=("
             + gPid.toString()
             + ")"
             + "]";
     switch (op.rpc_error.errno) {
       case ERR_SESSION_RESET:
-        message = " The replica can't be access, please confirm the address!";
+        message = " Disconnected from the replica-server due to internal error!";
         break;
       case ERR_TIMEOUT:
         message = " The operationTimeout is " + timeout + "ms!";