Merge pull request #243 from GroundWu/fix_5150_unit_transfer

fix: error OB_TENANT_NOT_IN_SERVER and try to refresh route after relogin
oceanbase · Nov 27, 2024 · 70ca8e1 · 70ca8e1
2 parents 3171e0d + c77ac53
commit 70ca8e1
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/main/java/com/alipay/oceanbase/rpc/table/ObTable.java b/src/main/java/com/alipay/oceanbase/rpc/table/ObTable.java
@@ -30,6 +30,7 @@
 import com.alipay.oceanbase.rpc.protocol.payload.impl.execute.*;
 import com.alipay.oceanbase.rpc.table.api.TableBatchOps;
 import com.alipay.oceanbase.rpc.table.api.TableQuery;
+import com.alipay.oceanbase.rpc.util.TraceUtil;
 import com.alipay.remoting.ConnectionEventHandler;
 import com.alipay.remoting.config.switches.GlobalSwitch;
 import com.alipay.remoting.connection.ConnectionFactory;
@@ -417,6 +418,10 @@ private ObPayload executeWithReconnect(ObTableConnection connection, final ObPay
             } catch (ObTableException ex) {
                 if (ex instanceof ObTableTenantNotInServerException && retryTimes < 2) {
                     needReconnect = true;
+                } else if (ex instanceof ObTableTenantNotInServerException) {
+                    String errMessage = TraceUtil.formatTraceMessage(connection, request,
+                            "meet ObTableTenantNotInServerException and has relogined, need to refresh route");
+                    throw new ObTableNeedFetchAllException(errMessage, ex.getErrorCode());
                 } else {
                     throw ex;
                 }