File tree Expand file tree Collapse file tree
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2929
3030import org .apache .flink .annotation .VisibleForTesting ;
3131import org .apache .flink .runtime .state .KeyGroupRangeAssignment ;
32- import org .apache .flink .util .Preconditions ;
3332import org .apache .log4j .LogManager ;
3433import org .apache .log4j .Logger ;
3534
@@ -309,9 +308,6 @@ public boolean canAssign() {
309308 * Remembers to invoke {@link #canAssign()} first.
310309 */
311310 public void assign () {
312- Preconditions .checkState (canAssign (),
313- "Can not assign insert to small file: assigned => "
314- + this .assigned + " totalUnassigned => " + this .totalUnassigned );
315311 this .assigned ++;
316312 }
317313 }
@@ -339,9 +335,6 @@ public boolean canAssign() {
339335 * Remembers to invoke {@link #canAssign()} first.
340336 */
341337 public void assign () {
342- Preconditions .checkState (canAssign (),
343- "Can not assign insert to new file: assigned => "
344- + this .assigned + " totalUnassigned => " + this .totalUnassigned );
345338 this .assigned ++;
346339 }
347340 }
You can’t perform that action at this time.
0 commit comments