lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-2068] Skip the assign state for SmallFileAssign when the state can not assign initially (#3148)

Browse Source
This commit is contained in:
Danny Chan
2021-06-25 08:57:56 +08:00
committed by GitHub
parent 218f2a6df8
commit e64fe55054
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssigner.java
View File

@@ -228,7 +228,7 @@ public class BucketAssigner implements AutoCloseable {
return false; return false;
} }
SmallFileAssignState state = states[assignIdx]; SmallFileAssignState state = states[assignIdx];
if (!state.canAssign()) { while (!state.canAssign()) {
assignIdx += 1; assignIdx += 1;
if (assignIdx >= states.length) { if (assignIdx >= states.length) {
noSpace = true; noSpace = true;
@@ -236,7 +236,6 @@ public class BucketAssigner implements AutoCloseable {
} }
// move to next slot if possible // move to next slot if possible
state = states[assignIdx]; state = states[assignIdx];
assert state.canAssign();
} }
state.assign(); state.assign();
return true; return true;