Skip to content

Commit 96624ad

Browse files
committed
fix getscanners bug
1 parent c08a2c8 commit 96624ad

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

src/main/java/com/alipay/oceanbase/hbase/OHTable.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1152,6 +1152,7 @@ public List<ResultScanner> call() throws IOException {
11521152

11531153
request = buildObTableQueryAsyncRequest(obTableQuery,
11541154
getTargetTableName(tableNameString));
1155+
request.setNeedTabletId(false);
11551156
request.setAllowDistributeScan(false);
11561157
String phyTableName = obTableClient.getPhyTableNameFromTableGroup(
11571158
request.getObTableQueryRequest(), tableNameString);
@@ -1188,6 +1189,7 @@ public List<ResultScanner> call() throws IOException {
11881189
String targetTableName = getTargetTableName(tableNameString, Bytes.toString(family),
11891190
configuration);
11901191
request = buildObTableQueryAsyncRequest(obTableQuery, targetTableName);
1192+
request.setNeedTabletId(false);
11911193
request.setAllowDistributeScan(false);
11921194
List<Partition> partitions = obTableClient
11931195
.getPartition(targetTableName, false);

0 commit comments

Comments
 (0)