correct holdTime when fetchAll is true when refreshing tableEntry

oceanbase · Jan 2, 2025 · f0c5cfc · f0c5cfc
1 parent bbdb4f8
commit f0c5cfc
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java b/src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java
@@ -1211,7 +1211,12 @@ public TableEntry getOrRefreshTableEntry(final String tableName, final boolean r
             if ((fetchAll && (fetchAllInterval < punishInterval))
                 || (!fetchAll && (interval < punishInterval))) {
                 if (waitForRefresh) {
-                    long toHoldTime = punishInterval - interval;
+                    long toHoldTime;
+                    if (fetchAll) {
+                        toHoldTime = punishInterval - fetchAllInterval;
+                    } else {
+                        toHoldTime = punishInterval - interval;
+                    }
                     logger
                         .info(
                             "punish table entry {} : table entry refresh time {} punish interval {} current time {}. wait for refresh times {}",