diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/FetchOperator.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/FetchOperator.java index 00efe4e..4cf9fb1 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/FetchOperator.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/FetchOperator.java @@ -310,8 +310,9 @@ private StructObjectInspector createRowInspector(StructObjectInspector current, Object[] partValues = new Object[partKeys.length]; for (int i = 0; i < partKeys.length; i++) { String key = partKeys[i]; - ObjectInspector oi = TypeInfoUtils.getStandardJavaObjectInspectorFromTypeInfo( - TypeInfoFactory.getPrimitiveTypeInfo(partKeyTypes[i])); + ObjectInspector oi = PrimitiveObjectInspectorFactory + .getPrimitiveWritableObjectInspector(TypeInfoFactory + .getPrimitiveTypeInfo(partKeyTypes[i])); partValues[i] = ObjectInspectorConverters. getConverter(PrimitiveObjectInspectorFactory.