From 41885a08e7706a8ea30ce320ad2ed14559e96562 Mon Sep 17 00:00:00 2001
From: shen <shenyunlong.syl@antgroup.com>
Date: Tue, 1 Apr 2025 15:38:07 +0800
Subject: [PATCH] [Fix] hbase multi partition scan return repetitive data

---
 src/main/java/com/alipay/oceanbase/hbase/OHTable.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/main/java/com/alipay/oceanbase/hbase/OHTable.java b/src/main/java/com/alipay/oceanbase/hbase/OHTable.java
index 4b3e3ad1..6bf1f7a7 100644
--- a/src/main/java/com/alipay/oceanbase/hbase/OHTable.java
+++ b/src/main/java/com/alipay/oceanbase/hbase/OHTable.java
@@ -1095,6 +1095,7 @@ public List<ResultScanner> call() throws IOException {
                         for (Partition partition : partitions) {
                             request.getObTableQueryRequest().setTableQueryPartId(
                                 partition.getPartId());
+                            request.setAllowDistributeScan(false);
                             clientQueryAsyncStreamResult = (ObTableClientQueryAsyncStreamResult) obTableClient
                                 .execute(request);
                             ClientStreamScanner clientScanner = new ClientStreamScanner(