diff --git a/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/AbstractQueryStreamResult.java b/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/AbstractQueryStreamResult.java index b4d2bc92..41aec267 100644 --- a/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/AbstractQueryStreamResult.java +++ b/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/AbstractQueryStreamResult.java @@ -258,7 +258,7 @@ protected ObPayload commonExecute(ObTableClient client, Logger logger, ((ObTableException) e).getErrorCode(), tryTimes, e); // tablet not exists, refresh table entry if (e instanceof ObTableNeedFetchAllException) { - client.getOrRefreshTableEntry(tableName, true, true, true); + client.getOrRefreshTableEntry(indexTableName, true, true, true); throw e; } } else {