This is an automated email from the ASF dual-hosted git repository.
wangxianghu 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 db93ad2 [HUDI-3277] Filter non-parquet files in bootstrap procedure
(#4639)
db93ad2 is described below
commit db93ad2f4bc9b3c357f065882c3d8cbb1c0b9c07
Author: wangxianghu <[email protected]>
AuthorDate: Wed Jan 19 21:13:51 2022 +0400
[HUDI-3277] Filter non-parquet files in bootstrap procedure (#4639)
---
.../java/org/apache/hudi/table/action/bootstrap/BootstrapUtils.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/bootstrap/BootstrapUtils.java
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/bootstrap/BootstrapUtils.java
index c6f0832..9b0db44 100644
---
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/bootstrap/BootstrapUtils.java
+++
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/bootstrap/BootstrapUtils.java
@@ -70,7 +70,7 @@ public class BootstrapUtils {
Integer level = (int) relativePath.chars().filter(ch -> ch ==
'/').count();
HoodieFileStatus hoodieFileStatus =
FileStatusUtils.fromFileStatus(topLevelStatus);
result.add(Pair.of(hoodieFileStatus, Pair.of(level, relativePath)));
- } else if (metaPathFilter.accept(topLevelStatus.getPath())) {
+ } else if (topLevelStatus.isDirectory() &&
metaPathFilter.accept(topLevelStatus.getPath())) {
subDirectories.add(topLevelStatus.getPath().toString());
}
}