use runtimeMaxWait to replace tryTimes in async stream result

Author: JackShi148

src/main/java/com/alipay/oceanbase/rpc/location/LocationUtil.java

@@ -1493,8 +1493,8 @@ private static ObPartitionEntry getPartitionLocationFromResultSetByTablet(TableE
             if (ObGlobal.isSchemaVersionSupport()) {
                 long curSchemaVersion = rs.getLong("schema_version");
                 String errMsg = "getPartitionLocationFromResultSetByTablet schema_version does not match for table: " + tableEntry.getTableEntryKey().getTableName()
-                        + ", exist version: " + schemaVersion
-                        + ", new version: " + curSchemaVersion;
+                                + ", exist version: " + schemaVersion
+                                + ", new version: " + curSchemaVersion;
                 checkSchemaVersionMatch(schemaVersion, curSchemaVersion, errMsg);
             }
             ReplicaLocation replica = buildReplicaLocation(rs);

src/main/java/com/alipay/oceanbase/rpc/location/model/TableRoute.java

@@ -159,7 +159,7 @@ public ObTable getFirstObTable() {
 
     public ObTableServerCapacity getServerCapacity() {
         if (tableClient.isOdpMode()) {
-            if (odpInfo.getObTable() == null) {
+            if (odpInfo == null || odpInfo.getObTable() == null) {
                 throw new IllegalStateException("client is not initialized and obTable is empty");
             }
             return odpInfo.getObTable().getServerCapacity();

src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/AbstractQueryStreamResult.java

@@ -17,7 +17,6 @@
 
 package com.alipay.oceanbase.rpc.protocol.payload.impl.execute.query;
 
-import com.alipay.oceanbase.rpc.ObGlobal;
 import com.alipay.oceanbase.rpc.ObTableClient;
 import com.alipay.oceanbase.rpc.bolt.transport.ObTableConnection;
 import com.alipay.oceanbase.rpc.bolt.transport.TransportCodes;

src/main/java/com/alipay/oceanbase/rpc/stream/ObTableClientQueryAsyncStreamResult.java

@@ -51,7 +51,6 @@ public void init() throws Exception {
         if (initialized) {
             return;
         }
-        int maxRetries = client.getTableEntryRefreshTryTimes();
         // init request
         ObTableQueryRequest request = new ObTableQueryRequest();
         request.setTableName(tableName);
@@ -69,6 +68,7 @@ public void init() throws Exception {
             Iterator<Map.Entry<Long, ObPair<Long, ObTableParam>>> it = expectant.entrySet()
                 .iterator();
             int retryTimes = 0;
+            long startExecute = System.currentTimeMillis();
             while (it.hasNext()) {
                 Map.Entry<Long, ObPair<Long, ObTableParam>> firstEntry = it.next();
                 try {
@@ -82,10 +82,11 @@ public void init() throws Exception {
                             tableName)));
                         it = expectant.entrySet().iterator();
                         retryTimes++;
-                        if (retryTimes > maxRetries) {
+                        long costMillis = System.currentTimeMillis() - startExecute;
+                        if (costMillis > client.getRuntimeMaxWait()) {
                             RUNTIME.error("Fail to get refresh table entry response after {}",
                                 retryTimes);
-                            throw new ObTableRetryExhaustedException(
+                            throw new ObTableTimeoutExcetion(
                                 "Fail to get refresh table entry response after " + retryTimes
                                         + "errorCode:"
                                         + ((ObTableNeedFetchMetaException) e).getErrorCode());
@@ -264,6 +265,7 @@ public boolean next() throws Exception {
             Iterator<Map.Entry<Long, ObPair<Long, ObTableParam>>> it = expectant.entrySet()
                 .iterator();
             int retryTimes = 0;
+            long startExecute = System.currentTimeMillis();
             while (it.hasNext()) {
                 Map.Entry<Long, ObPair<Long, ObTableParam>> entry = it.next();
                 try {
@@ -284,10 +286,11 @@ public boolean next() throws Exception {
                         }
                         it = expectant.entrySet().iterator();
                         retryTimes++;
-                        if (retryTimes > client.getTableEntryRefreshTryTimes()) {
+                        long costMillis = System.currentTimeMillis() - startExecute;
+                        if (costMillis > client.getRuntimeMaxWait()) {
                             RUNTIME.error("Fail to get refresh table entry response after {}",
                                 retryTimes);
-                            throw new ObTableRetryExhaustedException(
+                            throw new ObTableTimeoutExcetion(
                                 "Fail to get refresh table entry response after " + retryTimes);
                         }
                         continue;