Skip to content

Commit 47e46a3

Browse files
committed
revert LSBatch negateHbaseTimestamp
1 parent 379a534 commit 47e46a3

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

src/main/java/com/alipay/oceanbase/rpc/mutation/BatchOperation.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -319,9 +319,8 @@ private void negateHbaseTimestamp(Mutation mutation) {
319319
if (rowKey == null || rowKey.size() != 3) {
320320
throw new IllegalArgumentException("hbase rowkey length must be 3");
321321
} else {
322-
long ts = (long) mutation.getRowKeyValues().get(2);
323-
ObObj mutationObObj = new ObObj();
324-
mutationObObj.setValue(-ts);
322+
long ts = ((long) ((ObObj) mutation.getRowKeyValues().get(2)).getValue());
323+
((ObObj) mutation.getRowKeyValues().get(2)).setValue(-ts);
325324
}
326325
}
327326
}

0 commit comments

Comments
 (0)