diff --git a/src/main/java/com/fr/plugin/hdfs/repository/core/HDFSResourceRepository.java b/src/main/java/com/fr/plugin/hdfs/repository/core/HDFSResourceRepository.java
index 232a80b..3132486 100644
--- a/src/main/java/com/fr/plugin/hdfs/repository/core/HDFSResourceRepository.java
+++ b/src/main/java/com/fr/plugin/hdfs/repository/core/HDFSResourceRepository.java
@@ -188,6 +188,9 @@ public class HDFSResourceRepository extends BaseResourceRepository {
             FileStatus[] statuses = fs.listStatus(new Path(dir), new PathFilter() {
                 @Override
                 public boolean accept(Path path) {
+                    if (filter == null) {
+                        return true;
+                    }
                     return filter.accept(path.getName());
                 }
             });