Skip to content

Commit fe5f280

Browse files
committed
add comments
1 parent d82c7fb commit fe5f280

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3254,13 +3254,13 @@ private TableEntry getOrFetchODPPartitionMeta(String tableName, boolean needRene
32543254
if (ODPTableLocations.get(tableName) != null) {
32553255
odpTableEntry = ODPTableLocations.get(tableName);
32563256
long interval = System.currentTimeMillis() - odpTableEntry.getRefreshTimeMills();
3257-
// do not fetch partition meta if the refresh interval is less than 3 seconds
3257+
// do not fetch partition meta if and only if the refresh interval is less than 0.5 seconds
3258+
// and no need to fore renew
32583259
if (interval < reFetchInterval) {
32593260
if (!needRenew) {
32603261
lock.unlock();
32613262
return odpTableEntry;
32623263
}
3263-
32643264
Thread.sleep(reFetchInterval - interval);
32653265
}
32663266
}

0 commit comments

Comments
 (0)