Index: src/java/org/apache/hcatalog/pig/PigHCatUtil.java =================================================================== --- src/java/org/apache/hcatalog/pig/PigHCatUtil.java (revision 1328539) +++ src/java/org/apache/hcatalog/pig/PigHCatUtil.java (working copy) @@ -307,7 +307,7 @@ Type itemType = hfs.getType(); switch (itemType){ case BINARY: - result = new DataByteArray(((ByteArrayRef)o).getData()); + result = (o == null) ? null : new DataByteArray(((ByteArrayRef)o).getData()); break; case STRUCT: result = transformToTuple((List)o,hfs);