Skip to content

Commit ed7b5cd

Browse files
committed
[Fix] hbase multi partition scan return repetitive data
1 parent 8936673 commit ed7b5cd

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1095,6 +1095,7 @@ public List<ResultScanner> call() throws IOException {
10951095
for (Partition partition : partitions) {
10961096
request.getObTableQueryRequest().setTableQueryPartId(
10971097
partition.getPartId());
1098+
request.setAllowDistributeScan(false);
10981099
clientQueryAsyncStreamResult = (ObTableClientQueryAsyncStreamResult) obTableClient
10991100
.execute(request);
11001101
ClientStreamScanner clientScanner = new ClientStreamScanner(

0 commit comments

Comments
 (0)