From f0c5cfc5f9a26a4d550b4e4cdaf4eb2ecad9ad57 Mon Sep 17 00:00:00 2001 From: JackShi148 Date: Thu, 2 Jan 2025 17:00:13 +0800 Subject: [PATCH] correct holdTime when fetchAll is true when refreshing tableEntry --- src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java b/src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java index 606420f0..03d92b32 100644 --- 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 {}",