@@ -154,7 +154,7 @@ public class OHTable implements Table {
154
154
/**
155
155
* the buffer of put request
156
156
*/
157
- private final ArrayList <Put > writeBuffer = new ArrayList <Put >();
157
+ private final ArrayList <Put > writeBuffer = new ArrayList <Put >();
158
158
/**
159
159
* when the put request reach the write buffer size the do put will
160
160
* flush commits automatically
@@ -1123,13 +1123,13 @@ public List<ResultScanner> call() throws IOException {
1123
1123
1124
1124
request = buildObTableQueryAsyncRequest (obTableQuery ,
1125
1125
getTargetTableName (tableNameString ));
1126
+ request .setAllowDistributeScan (false );
1126
1127
String phyTableName = obTableClient .getPhyTableNameFromTableGroup (
1127
1128
request .getObTableQueryRequest (), tableNameString );
1128
1129
List <Partition > partitions = obTableClient .getPartition (phyTableName , false );
1129
1130
for (Partition partition : partitions ) {
1130
1131
request .getObTableQueryRequest ().setTableQueryPartId (
1131
1132
partition .getPartId ());
1132
- request .setAllowDistributeScan (false );
1133
1133
clientQueryAsyncStreamResult = (ObTableClientQueryAsyncStreamResult ) obTableClient
1134
1134
.execute (request );
1135
1135
ClientStreamScanner clientScanner = new ClientStreamScanner (
@@ -1159,6 +1159,7 @@ public List<ResultScanner> call() throws IOException {
1159
1159
String targetTableName = getTargetTableName (tableNameString , Bytes .toString (family ),
1160
1160
configuration );
1161
1161
request = buildObTableQueryAsyncRequest (obTableQuery , targetTableName );
1162
+ request .setAllowDistributeScan (false );
1162
1163
List <Partition > partitions = obTableClient
1163
1164
.getPartition (targetTableName , false );
1164
1165
for (Partition partition : partitions ) {
0 commit comments