Index: ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java (revision 1459197) +++ ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java (working copy) @@ -7477,10 +7477,8 @@ // Finally add the partitioning columns for (FieldSchema part_col : tab.getPartCols()) { LOG.trace("Adding partition col: " + part_col); - // TODO: use the right type by calling part_col.getType() instead of - // String.class rwsch.put(alias, part_col.getName(), new ColumnInfo(part_col.getName(), - TypeInfoFactory.stringTypeInfo, alias, true)); + TypeInfoFactory.getPrimitiveTypeInfo(part_col.getType()), alias, true)); } // put all virutal columns in RowResolver.