diff --git hcatalog/core/src/main/java/org/apache/hive/hcatalog/data/HCatRecordSerDe.java hcatalog/core/src/main/java/org/apache/hive/hcatalog/data/HCatRecordSerDe.java index 8a8620c..ec5a94e 100644 --- hcatalog/core/src/main/java/org/apache/hive/hcatalog/data/HCatRecordSerDe.java +++ hcatalog/core/src/main/java/org/apache/hive/hcatalog/data/HCatRecordSerDe.java @@ -265,7 +265,9 @@ public static Object serializeField(Object field, ObjectInspector fieldObjectIns private static Object serializePrimitiveField(Object field, ObjectInspector fieldObjectInspector) { - + if (field == null) { + return null; + } Object f = ((PrimitiveObjectInspector) fieldObjectInspector).getPrimitiveJavaObject(field); if (f != null && HCatContext.INSTANCE.getConf().isPresent()) { Configuration conf = HCatContext.INSTANCE.getConf().get();