Skip to content

Commit 74eaecd

Browse files
committed
add refresh tableGroup cache in query
1 parent a55bae2 commit 74eaecd

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientQueryImpl.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -230,7 +230,9 @@ indexTableName, getPartId(), false, false, false,
230230
partitionObTables.put(table.getLeft(), table);
231231
} catch (ObTableNotExistException e) {
232232
if (this.entityType == ObTableEntityType.HKV
233-
&& obTableClient.isTableGroupName(tableName)) {
233+
&& obTableClient.isTableGroupName(tableName)
234+
&& obTableClient.getTableGroupInverted().get(indexTableName) != null) {
235+
obTableClient.eraseTableGroupFromCache(indexTableName);
234236
indexTableName = obTableClient.tryGetTableNameFromTableGroupCache(
235237
tableName, true);
236238
ObPair<Long, ObTableParam> table = obTableClient.getTableWithPartId(

0 commit comments

Comments
 (0)