diff --git hcatalog-pig-adapter/src/main/java/org/apache/hcatalog/pig/HCatBaseLoader.java hcatalog-pig-adapter/src/main/java/org/apache/hcatalog/pig/HCatBaseLoader.java index 031afda..642d6bb 100644 --- hcatalog-pig-adapter/src/main/java/org/apache/hcatalog/pig/HCatBaseLoader.java +++ hcatalog-pig-adapter/src/main/java/org/apache/hcatalog/pig/HCatBaseLoader.java @@ -135,8 +135,11 @@ public abstract class HCatBaseLoader extends LoadFunc implements LoadMetadata, L if (p.getFileSystem(conf).isFile(p)) { sizeInBytes += p.getFileSystem(conf).getFileStatus(p).getLen(); } else { - for (FileStatus child : p.getFileSystem(conf).listStatus(p)) { - sizeInBytes += child.getLen(); + FileStatus[] fileStatuses = p.getFileSystem(conf).listStatus(p); + if (fileStatuses != null) { + for (FileStatus child : fileStatuses) { + sizeInBytes += child.getLen(); + } } } } catch (IOException e) {