Skip to content

Commit d82c7fb

Browse files
committed
everytime force new if flag is true
1 parent 8365ecd commit d82c7fb

File tree

1 file changed

+8
-3
lines changed

1 file changed

+8
-3
lines changed

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

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3226,6 +3226,7 @@ private TableEntry getOrFetchODPPartitionMeta(String tableName, boolean needRene
32263226
}
32273227
TableEntry odpTableEntry = ODPTableLocations.get(tableName);
32283228
Long lastOdpRefreshTimeMills = null;
3229+
Long reFetchInterval = 500L;
32293230

32303231
// already have odpTableEntry
32313232
if (odpTableEntry != null) {
@@ -3254,9 +3255,13 @@ private TableEntry getOrFetchODPPartitionMeta(String tableName, boolean needRene
32543255
odpTableEntry = ODPTableLocations.get(tableName);
32553256
long interval = System.currentTimeMillis() - odpTableEntry.getRefreshTimeMills();
32563257
// do not fetch partition meta if the refresh interval is less than 3 seconds
3257-
if (interval < 3000L) {
3258-
lock.unlock();
3259-
return odpTableEntry;
3258+
if (interval < reFetchInterval) {
3259+
if (!needRenew) {
3260+
lock.unlock();
3261+
return odpTableEntry;
3262+
}
3263+
3264+
Thread.sleep(reFetchInterval - interval);
32603265
}
32613266
}
32623267

0 commit comments

Comments
 (0)