[hudi] branch master updated: [HUDI-3277] Filter non-parquet files in bootstrap procedure (#4639)

[wa...@apache.org]

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 <wa...@apache.org>
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());
       }
     }