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 <[email protected]>
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)) {
