Skip to content

Commit cc37f37

Browse files
committed
correct holdTime when fetchAll is true when refreshing tableEntry
1 parent 082d75a commit cc37f37

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1213,7 +1213,7 @@ public TableEntry getOrRefreshTableEntry(final String tableName, final boolean r
12131213
if ((fetchAll && (fetchAllInterval < punishInterval))
12141214
|| (!fetchAll && (interval < punishInterval))) {
12151215
if (waitForRefresh) {
1216-
long toHoldTime = punishInterval - interval;
1216+
long toHoldTime = fetchAll ? (punishInterval - fetchAllInterval) : (punishInterval - interval);
12171217
logger
12181218
.info(
12191219
"punish table entry {} : table entry refresh time {} punish interval {} current time {}. wait for refresh times {}ms",

0 commit comments

Comments
 (0)