From 8a637aebd39dc0e89d69dcc35d2f3e9894950f65 Mon Sep 17 00:00:00 2001 From: SiCheng-Zheng Date: Fri, 12 Aug 2022 23:31:48 +0800 Subject: [PATCH] HBASE-27301 Add Delete addFamilyVersion timestamp verify --- .../src/main/java/org/apache/hadoop/hbase/client/Delete.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Delete.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Delete.java index 545e8c38c4b0..8ec670d445f9 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Delete.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Delete.java @@ -190,6 +190,9 @@ public Delete addFamily(final byte[] family, final long timestamp) { * @return this for invocation chaining */ public Delete addFamilyVersion(final byte[] family, final long timestamp) { + if (timestamp < 0) { + throw new IllegalArgumentException("Timestamp cannot be negative. ts=" + timestamp); + } List list = getCellList(family); list.add(new KeyValue(row, family, null, timestamp, KeyValue.Type.DeleteFamilyVersion)); return this;