Skip to content

Commit d7b1022

Browse files
committed
fix regress
1 parent eb3d41b commit d7b1022

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/AbstractQueryStreamResult.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -232,7 +232,8 @@ protected ObPayload commonExecute(ObTableClient client, Logger logger,
232232
} else if (e instanceof ObTableException) {
233233
if ((((ObTableException) e).getErrorCode() == ResultCodes.OB_TABLE_NOT_EXIST.errorCode || ((ObTableException) e)
234234
.getErrorCode() == ResultCodes.OB_NOT_SUPPORTED.errorCode)
235-
&& ((ObTableQueryAsyncRequest) request).getObTableQueryRequest().getTableQuery().isHbaseQuery()
235+
&& ((request instanceof ObTableQueryAsyncRequest && ((ObTableQueryAsyncRequest) request).getObTableQueryRequest().getTableQuery().isHbaseQuery())
236+
|| (request instanceof ObTableQueryRequest && ((ObTableQueryRequest) request).getTableQuery().isHbaseQuery()))
236237
&& client.getTableGroupInverted().get(indexTableName) != null) {
237238
// table not exists && hbase mode && table group exists , three condition both
238239
client.eraseTableGroupFromCache(tableName);

0 commit comments

Comments
 (0)