add new rerouting errorcode

Author: maochongxin

src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java

@@ -789,10 +789,8 @@ public void calculateContinuousFailure(String tableName, String errorMsg) throws
     }
 
     public void resetContinuousFailureByTableName(String tableName) {
-        tableContinuousFailures.computeIfPresent(tableName, (k, v) -> {
-            v.set(0);
-            return v;
-        });
+        AtomicLong res = tableContinuousFailures.get(tableName);
+        res.set(0);
     }
 
     /**

src/main/java/com/alipay/oceanbase/rpc/bolt/transport/ObTableRemoting.java

@@ -174,9 +174,11 @@ protected InvokeFuture createInvokeFuture(Connection conn, RemotingCommand reque
 
     private boolean needFetchAll(int errorCode) {
         return errorCode == ResultCodes.OB_PARTITION_NOT_EXIST.errorCode
-                || errorCode == ResultCodes.OB_INVALID_PARTITION.errorCode
-                || errorCode == ResultCodes.OB_UNKNOWN_PARTITION.errorCode
-                || errorCode == ResultCodes.OB_PARTITION_NOT_MATCH.errorCode
-                || errorCode == ResultCodes.OB_TABLET_NOT_EXIST.errorCode;
+               || errorCode == ResultCodes.OB_INVALID_PARTITION.errorCode
+               || errorCode == ResultCodes.OB_UNKNOWN_PARTITION.errorCode
+               || errorCode == ResultCodes.OB_PARTITION_NOT_MATCH.errorCode
+               || errorCode == ResultCodes.OB_TABLET_NOT_EXIST.errorCode
+               || errorCode == ResultCodes.OB_REPLICA_NOT_READABLE.errorCode
+               || errorCode == ResultCodes.OB_SCHEMA_EAGAIN.errorCode;
     }
 }

src/main/java/com/alipay/oceanbase/rpc/protocol/payload/ResultCodes.java

@@ -633,6 +633,7 @@ public enum ResultCodes {
     OB_IGNORE_SQL_IN_RESTORE(-5309), //
     OB_ERR_UNEXPECTED_TZ_TRANSITION(-5310), //
     OB_ERR_INVALID_COLUMN_ID(-5311), //
+    OB_SCHEMA_EAGAIN(-5627), //
     OB_TRANSACTION_SET_VIOLATION(-6001), //
     OB_TRANS_ROLLBACKED(-6002), //
     OB_ERR_EXCLUSIVE_LOCK_CONFLICT(-6003), //

src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientBatchOpsImpl.java

@@ -383,7 +383,6 @@ public void partitionExecute(ObTableOperationResult[] results,
                                 tableName, partId, ((ObTableException) ex).getErrorCode(),
                                 tryTimes, ex);
                         if (ex instanceof ObTableRoutingWrongException) {
-                            System.out.println("need fetchAll refresh");
                             obTableClient.getOrRefreshTableEntry(tableName, true, obTableClient.isTableEntryRefreshIntervalWait(), true);
                             // reset failure count while fetch all route info
                             obTableClient.resetContinuousFailureByTableName(tableName);