Skip to content

Commit c70d6cc

Browse files
committed
revert unused commit
1 parent d51acc5 commit c70d6cc

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/AbstractQueryStreamResult.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -155,7 +155,6 @@ protected ObPayload commonExecute(ObTableClient client, Logger logger,
155155
result = subObTable.executeWithConnection(request, connectionRef);
156156
} else {
157157
result = subObTable.execute(request);
158-
System.err.println("indexTableName:" +indexTableName);
159158
if (result != null && result.getPcode() == Pcodes.OB_TABLE_API_MOVE) {
160159
ObTableApiMove moveResponse = (ObTableApiMove) result;
161160
client.getRouteTableRefresher().addTableIfAbsent(indexTableName, true);
@@ -376,6 +375,7 @@ protected Map<Long, ObPair<Long, ObTableParam>> buildPartitions(ObTableClient cl
376375
if (!client.isOdpMode()) {
377376
indexTableName = client.getIndexTableName(tableName, indexName, tableQuery.getScanRangeColumns(), false);
378377
}
378+
379379
for (ObNewRange range : tableQuery.getKeyRanges()) {
380380
ObRowKey startKey = range.getStartKey();
381381
int startKeySize = startKey.getObjs().size();

src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientQueryImpl.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -248,6 +248,7 @@ public Map<Long, ObPair<Long, ObTableParam>> initPartitions(ObTableQuery tableQu
248248
if (!this.obTableClient.isOdpMode()) {
249249
indexTableName = obTableClient.getIndexTableName(tableName, indexName, tableQuery.getScanRangeColumns(), false);
250250
}
251+
251252
for (ObNewRange range : tableQuery.getKeyRanges()) {
252253
ObRowKey startKey = range.getStartKey();
253254
int startKeySize = startKey.getObjs().size();

0 commit comments

Comments
 (0)