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 d90f286a197 [HUDI-5568] Fix the BucketStreamWriteFunction to rebase the local filesystem instance instead (#7685) d90f286a197 is described below commit d90f286a1971af952becea2267ed772f5e5e4ec7 Author: luokey <854194...@qq.com> AuthorDate: Mon Jan 30 23:01:14 2023 -0500 [HUDI-5568] Fix the BucketStreamWriteFunction to rebase the local filesystem instance instead (#7685) Should use `writeClient. getHoodieTable(). getHoodieView()` to determine the fileSystemView --- .../java/org/apache/hudi/sink/bucket/BucketStreamWriteFunction.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bucket/BucketStreamWriteFunction.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bucket/BucketStreamWriteFunction.java index c989b4eb29a..cf06dbc18d6 100644 --- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bucket/BucketStreamWriteFunction.java +++ b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bucket/BucketStreamWriteFunction.java @@ -156,7 +156,7 @@ public class BucketStreamWriteFunction<I> extends StreamWriteFunction<I> { // Load existing fileID belongs to this task Map<Integer, String> bucketToFileIDMap = new HashMap<>(); - this.writeClient.getHoodieTable().getFileSystemView().getAllFileGroups(partition).forEach(fileGroup -> { + this.writeClient.getHoodieTable().getHoodieView().getAllFileGroups(partition).forEach(fileGroup -> { String fileID = fileGroup.getFileGroupId().getFileId(); int bucketNumber = BucketIdentifier.bucketIdFromFileId(fileID); if (isBucketToLoad(bucketNumber, partition)) {