diff --git a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/PartialUpdateMergeFunction.java b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/PartialUpdateMergeFunction.java index 540391369bca..bf21e5d40313 100644 --- a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/PartialUpdateMergeFunction.java +++ b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/PartialUpdateMergeFunction.java @@ -94,11 +94,6 @@ public void add(KeyValue kv) { return; } - if (kv.valueKind() == RowKind.UPDATE_BEFORE) { - throw new IllegalArgumentException( - "Partial update can not accept update_before records, it is a bug."); - } - String msg = String.join( "By default, Partial update can not accept delete records,"