[HUDI-5187] Remove the preCondition check of BucketAssigner assign st…

…ate (#7170)
apache · Dec 15, 2022 · d9a4d21 · d9a4d21
1 parent 738f673
commit d9a4d21
Showing 1 changed file with 0 additions and 7 deletions.
diff --git a/...-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssigner.java b/...-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++;
     }
   }