Skip to content

Commit 440954f

Browse files
committed
[Fix] fix conflict after rebase master
1 parent aa644ca commit 440954f

File tree

1 file changed

+2
-7
lines changed

1 file changed

+2
-7
lines changed

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

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -341,18 +341,13 @@ public Map<Long, Map<Long, ObPair<ObTableParam, List<ObPair<Integer, ObTableSing
341341
for (int j = 0; j < rowKeySize; j++) {
342342
rowKey[j] = rowkeyObjs.get(j).getValue();
343343
}
344-
<<<<<<< HEAD
345-
ObPair<Long, ObTableParam> tableObPair= obTableClient.getTable(tableName, rowKey,
346-
false, false, obTableClient.getRoute(false));
347-
=======
348344

349345
String real_tableName = tableName;
350346
if (this.entityType == ObTableEntityType.HKV && obTableClient.isTableGroupName(tableName)) {
351347
real_tableName = obTableClient.tryGetTableNameFromTableGroupCache(tableName, false);
352348
}
353-
ObPair<Long, ObTableParam> tableObPair= obTableClient.getTableBySingleRowKeyWithRoute(real_tableName, rowKey,
354-
false, false, false, obTableClient.getRoute(false));
355-
>>>>>>> 10c56c8 (lsop support tablegroup (#188))
349+
ObPair<Long, ObTableParam> tableObPair= obTableClient.getTable(real_tableName, rowKey,
350+
false, false, obTableClient.getRoute(false));
356351
long lsId = tableObPair.getRight().getLsId();
357352

358353
Map<Long, ObPair<ObTableParam, List<ObPair<Integer, ObTableSingleOp>>>> tabletOperations

0 commit comments

Comments
 (0)