lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-1909] Skip Commits with empty files (#3045)

Browse Source
This commit is contained in:
Vinay Patil
2021-06-07 19:28:19 +05:30
committed by GitHub
parent 08464a6a5b
commit 0d0dc6fb07
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
hudi-flink/src/main/java/org/apache/hudi/source/StreamReadMonitoringFunction.java
View File

@@ -225,7 +225,8 @@ public class StreamReadMonitoringFunction
Set<String> writePartitions = getWritePartitionPaths(metadataList); Set<String> writePartitions = getWritePartitionPaths(metadataList);
FileStatus[] fileStatuses = getWritePathsOfInstants(metadataList); FileStatus[] fileStatuses = getWritePathsOfInstants(metadataList);
if (fileStatuses.length == 0) { if (fileStatuses.length == 0) {
throw new HoodieException("No files found for reading in user provided path."); LOG.warn("No files found for reading in user provided path.");
return;
} }
HoodieTableFileSystemView fsView = new HoodieTableFileSystemView(metaClient, commitTimeline, fileStatuses); HoodieTableFileSystemView fsView = new HoodieTableFileSystemView(metaClient, commitTimeline, fileStatuses);