diff --git serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/primitive/JavaBinaryObjectInspector.java serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/primitive/JavaBinaryObjectInspector.java index 0de8385..a4f44eb 100644 --- serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/primitive/JavaBinaryObjectInspector.java +++ serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/primitive/JavaBinaryObjectInspector.java @@ -45,7 +45,15 @@ public class JavaBinaryObjectInspector extends AbstractPrimitiveJavaObjectInspec @Override public BytesWritable getPrimitiveWritableObject(Object o) { - return o == null ? null : new BytesWritable(((ByteArrayRef)o).getData()); + byte[] data; + if (o instanceof ByteArrayRef) { + data = ((ByteArrayRef) o).getData(); + } else if (o instanceof byte[]) { + data = (byte[]) o; + } else { + return null; + } + return new BytesWritable(data); } @Override