Skip to content

Commit cff129c

Browse files
shenyunlongstuBirdFly
authored andcommitted
[Fix] hbase multi partition scan return repetitive data
(cherry picked from commit ed7b5cd)
1 parent a616f2a commit cff129c

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1128,7 +1128,8 @@ public List<ResultScanner> call() throws IOException {
11281128
List<Partition> partitions = obTableClient.getPartition(phyTableName, false);
11291129
for (Partition partition : partitions) {
11301130
request.getObTableQueryRequest().setTableQueryPartId(
1131-
partition.getPartId());
1131+
partition.getPartId());
1132+
request.setAllowDistributeScan(false);
11321133
clientQueryAsyncStreamResult = (ObTableClientQueryAsyncStreamResult) obTableClient
11331134
.execute(request);
11341135
ClientStreamScanner clientScanner = new ClientStreamScanner(

0 commit comments

Comments
 (0)