From ff0e8da529d3a8028a8781e3a0aeb3441edbf94a Mon Sep 17 00:00:00 2001 From: "yuzhao.cyz" Date: Wed, 9 Nov 2022 17:50:34 +0800 Subject: [PATCH] [HUDI-5187] Remove the preCondition check of BucketAssigner assign state --- .../org/apache/hudi/sink/partitioner/BucketAssigner.java | 7 ------- 1 file changed, 7 deletions(-) diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssigner.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssigner.java index e73890f3b54ba..ebb47a91eb573 100644 --- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssigner.java +++ b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssigner.java @@ -29,7 +29,6 @@ import org.apache.flink.annotation.VisibleForTesting; import org.apache.flink.runtime.state.KeyGroupRangeAssignment; -import org.apache.flink.util.Preconditions; import org.apache.log4j.LogManager; import org.apache.log4j.Logger; @@ -309,9 +308,6 @@ public boolean canAssign() { * Remembers to invoke {@link #canAssign()} first. */ public void assign() { - Preconditions.checkState(canAssign(), - "Can not assign insert to small file: assigned => " - + this.assigned + " totalUnassigned => " + this.totalUnassigned); this.assigned++; } } @@ -339,9 +335,6 @@ public boolean canAssign() { * Remembers to invoke {@link #canAssign()} first. */ public void assign() { - Preconditions.checkState(canAssign(), - "Can not assign insert to new file: assigned => " - + this.assigned + " totalUnassigned => " + this.totalUnassigned); this.assigned++; } }