Skip to content

Commit b699555

Browse files
committed
do compatibility for batch get and batch put + delete
1 parent 66afd6c commit b699555

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

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

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -646,7 +646,7 @@ public void batch(final List<? extends Row> actions, final Object[] results) thr
646646
BatchError batchError = new BatchError();
647647
obTableClient.setRuntimeBatchExecutor(executePool);
648648
List<Integer> resultMapSingleOp = new LinkedList<>();
649-
if (!ObGlobal.isHBaseBatchGetSupport()) {
649+
if (!ObGlobal.isHBaseBatchSupport()) {
650650
try {
651651
compatOldServerBatch(actions, results, batchError);
652652
} catch (Exception e) {
@@ -2064,6 +2064,9 @@ private BatchOperation buildBatchOperation(String tableName, List<? extends Row>
20642064
singleOpResultNum = 0;
20652065
posInList++;
20662066
if (row instanceof Get) {
2067+
if (!ObGlobal.isHBaseBatchGetSupport()) {
2068+
throw new FeatureNotSupportedException("server does not support batch get");
2069+
}
20672070
++singleOpResultNum;
20682071
Get get = (Get) row;
20692072
ObTableQuery obTableQuery;

0 commit comments

Comments
 (0)