Skip to content

Commit 0a5381d

Browse files
stuBirdFlymiyuan-ljr
authored andcommitted
hbase tablename bug fix (#237)
1 parent 5e6889b commit 0a5381d

File tree

2 files changed

+4
-10
lines changed

2 files changed

+4
-10
lines changed

src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3140,7 +3140,6 @@ public ObPayload execute(final ObTableAbstractOperationRequest request) throws E
31403140
} else if (request instanceof ObTableQueryRequest) {
31413141
// TableGroup -> TableName
31423142
String tableName = request.getTableName();
3143-
tableName = getPhyTableNameFromTableGroup(((ObTableQueryRequest) request), tableName);
31443143
ObTableClientQueryImpl tableQuery = new ObTableClientQueryImpl(tableName,
31453144
((ObTableQueryRequest) request).getTableQuery(), this);
31463145
tableQuery.setEntityType(request.getEntityType());

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

Lines changed: 4 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@
2424
import com.alipay.oceanbase.rpc.protocol.payload.ObPayload;
2525
import com.alipay.oceanbase.rpc.protocol.payload.ResultCodes;
2626
import com.alipay.oceanbase.rpc.protocol.payload.impl.ObRowKey;
27+
import com.alipay.oceanbase.rpc.protocol.payload.impl.execute.ObTableEntityType;
2728
import com.alipay.oceanbase.rpc.protocol.payload.impl.execute.aggregation.ObTableAggregationType;
2829
import com.alipay.oceanbase.rpc.protocol.payload.impl.execute.query.*;
2930
import com.alipay.oceanbase.rpc.stream.ObTableClientQueryAsyncStreamResult;
@@ -192,14 +193,6 @@ private AbstractQueryStreamResult commonExecute(InitQueryResultCallback<Abstract
192193
}
193194
}
194195

195-
// set correct table group name for hbase
196-
if (tableQuery.isHbaseQuery()
197-
&& obTableClient.getTableGroupInverted().containsKey(tableName)
198-
&& tableName.equalsIgnoreCase(obTableClient.getTableGroupCache().get(
199-
obTableClient.getTableGroupInverted().get(tableName)))) {
200-
tableName = obTableClient.getTableGroupInverted().get(tableName);
201-
}
202-
203196
// init query stream result
204197
AbstractQueryStreamResult streamResult = callable.execute();
205198

@@ -266,7 +259,9 @@ public Map<Long, ObPair<Long, ObTableParam>> initPartitions(ObTableQuery tableQu
266259
end[i] = endKey.getObj(i).isMinObj() || endKey.getObj(i).isMaxObj() ?
267260
endKey.getObj(i) : endKey.getObj(i).getValue();
268261
}
269-
262+
if (this.entityType == ObTableEntityType.HKV && obTableClient.isTableGroupName(tableName)) {
263+
indexTableName = obTableClient.tryGetTableNameFromTableGroupCache(tableName, false);
264+
}
270265
ObBorderFlag borderFlag = range.getBorderFlag();
271266
List<ObPair<Long, ObTableParam>> pairs = this.obTableClient.getTables(indexTableName,
272267
tableQuery, start, borderFlag.isInclusiveStart(), end, borderFlag.isInclusiveEnd(),

0 commit comments

Comments
 (0)