fix schema version not updated in retry

Author: JackShi148

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

@@ -1452,6 +1452,7 @@ private static TableEntry getTableEntryFromResultSet(TableEntryKey key, ResultSe
         }
         TableLocation tableLocation = new TableLocation();
         tableLocation.setReplicaLocations(replicaLocations);
+        logger.info("refresh meta get new schema_version: {}", schemaVersion);
         if (!replicaLocations.isEmpty()) {
             entry.setTableId(tableId);
             entry.setTableLocation(tableLocation);

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

@@ -329,7 +329,10 @@ public TableEntry refreshPartitionLocation(TableEntry tableEntry, String tableNa
                     throw e;
                 } catch (ObTableSchemaVersionMismatchException e) {
                     RUNTIME.error(
-                        "refresh partition location meet schema_version mismatched exception", e);
+                        "refresh partition location meet schema_version mismatched exception, tryTimes: {}", i, e);
+                    if (i >= retryTimes - 1) {
+                        throw e;
+                    }
                     long schemaVersion = tableEntry.getSchemaVersion();
                     // sleep over waiting interval of refreshing meta to refresh meta
                     long interval = System.currentTimeMillis()
@@ -340,7 +343,7 @@ public TableEntry refreshPartitionLocation(TableEntry tableEntry, String tableNa
                     tableEntry = locations.get(tableName);
                     // if schema_version has been updated, directly retry
                     if (schemaVersion == tableEntry.getSchemaVersion()) {
-                        refreshMeta(tableName, serverRoster, sysUA);
+                        tableEntry = refreshMeta(tableName, serverRoster, sysUA);
                     }
                 } catch (ObTableEntryRefreshException e) {
                     RUNTIME.error("refresh partition location meet entry refresh exception", e);
@@ -453,7 +456,10 @@ public TableEntry refreshTabletLocationBatch(TableEntry tableEntry, String table
                     throw e;
                 } catch (ObTableSchemaVersionMismatchException e) {
                     RUNTIME.error(
-                        "refresh location in batch meet schema_version mismatched exception", e);
+                        "refresh location in batch meet schema_version mismatched exception, tryTimes: {}", i, e);
+                    if (i >= retryTimes - 1) {
+                        throw e;
+                    }
                     long schemaVersion = tableEntry.getSchemaVersion();
                     // sleep over waiting interval of refreshing meta to refresh meta
                     long interval = System.currentTimeMillis()
@@ -464,7 +470,7 @@ public TableEntry refreshTabletLocationBatch(TableEntry tableEntry, String table
                     tableEntry = locations.get(tableName);
                     // if schema_version has been updated, directly retry
                     if (schemaVersion == tableEntry.getSchemaVersion()) {
-                        refreshMeta(tableName, serverRoster, sysUA);
+                        tableEntry = refreshMeta(tableName, serverRoster, sysUA);
                     }
                 } catch (ObTableEntryRefreshException e) {
                     RUNTIME.error("refresh location in batch meet entry refresh exception", e);