This is an automated email from the ASF dual-hosted git repository.
danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new 9f66ac0fb4b [HUDI-7942] Fix SmallFileAssignState#totalUnassigned
naming error (#11544)
9f66ac0fb4b is described below
commit 9f66ac0fb4b28a0928f4f4dc4aae4271b0af95f8
Author: usberkeley <[email protected]>
AuthorDate: Mon Jul 1 09:40:59 2024 +0800
[HUDI-7942] Fix SmallFileAssignState#totalUnassigned naming error (#11544)
---
.../main/java/org/apache/hudi/sink/partitioner/BucketAssigner.java | 6 +++---
1 file changed, 3 insertions(+), 3 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 8e1fa96e5a3..af60ed74d3f 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
@@ -291,17 +291,17 @@ public class BucketAssigner implements AutoCloseable {
*/
private static class SmallFileAssignState {
long assigned;
- long totalUnassigned;
+ long total;
final String fileId;
SmallFileAssignState(long parquetMaxFileSize, SmallFile smallFile, long
averageRecordSize) {
this.assigned = 0;
- this.totalUnassigned = (parquetMaxFileSize - smallFile.sizeBytes) /
averageRecordSize;
+ this.total = (parquetMaxFileSize - smallFile.sizeBytes) /
averageRecordSize;
this.fileId = smallFile.location.getFileId();
}
public boolean canAssign() {
- return this.totalUnassigned > 0 && this.totalUnassigned > this.assigned;
+ return this.total > 0 && this.total > this.assigned;
}
/**
