Merge pull request #195 from oceanbase/fix-getscanners-dist-execute

fix getScanners dist execute

Author: WeiXinChan

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

@@ -139,7 +139,7 @@ public class OHTable implements HTableInterface {
     /**
      * the buffer of put request
      */
-    private final ArrayList<Put> writeBuffer            = new ArrayList<Put>();
+    private final ArrayList<Put>  writeBuffer            = new ArrayList<Put>();
     /**
      * when the put request reach the write buffer size the do put will
      * flush commits automatically
@@ -1080,13 +1080,13 @@ public List<ResultScanner> call() throws IOException {
 
                         request = buildObTableQueryAsyncRequest(obTableQuery,
                             getTargetTableName(tableNameString));
+                        request.setAllowDistributeScan(false);
                         String phyTableName = obTableClient.getPhyTableNameFromTableGroup(
                             request.getObTableQueryRequest(), tableNameString);
                         List<Partition> partitions = obTableClient.getPartition(phyTableName, false);
                         for (Partition partition : partitions) {
                             request.getObTableQueryRequest().setTableQueryPartId(
                                 partition.getPartId());
-                            request.setAllowDistributeScan(false);
                             clientQueryAsyncStreamResult = (ObTableClientQueryAsyncStreamResult) obTableClient
                                 .execute(request);
                             ClientStreamScanner clientScanner = new ClientStreamScanner(
@@ -1106,6 +1106,7 @@ public List<ResultScanner> call() throws IOException {
                             String targetTableName = getTargetTableName(tableNameString, Bytes.toString(family),
                                     configuration);
                             request = buildObTableQueryAsyncRequest(obTableQuery, targetTableName);
+                            request.setAllowDistributeScan(false);
                             List<Partition> partitions = obTableClient
                                 .getPartition(targetTableName, false);
                             for (Partition partition : partitions) {