diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/ColumnStatsUpdateTask.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/ColumnStatsUpdateTask.java index eb4488a..2acc777 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/ColumnStatsUpdateTask.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/ColumnStatsUpdateTask.java @@ -93,14 +93,14 @@ private ColumnStatistics constructColumnStatsFromInput() statsObj.setColName(colName.get(0)); statsObj.setColType(colType.get(0)); - + ColumnStatisticsData statsData = new ColumnStatisticsData(); - + String columnType = colType.get(0); if (columnType.equalsIgnoreCase("long") || columnType.equalsIgnoreCase("tinyint") - || columnType.equalsIgnoreCase("smallint") || columnType.equalsIgnoreCase("int") - || columnType.equalsIgnoreCase("bigint")) { + || columnType.equalsIgnoreCase("smallint") || columnType.equalsIgnoreCase("int") + || columnType.equalsIgnoreCase("bigint") || columnType.equalsIgnoreCase("timestamp")) { LongColumnStatsData longStats = new LongColumnStatsData(); longStats.setNumNullsIsSet(false); longStats.setNumDVsIsSet(false); @@ -121,7 +121,6 @@ private ColumnStatistics constructColumnStatsFromInput() } else { throw new SemanticException("Unknown stat"); } - } statsData.setLongStats(longStats); statsObj.setStatsData(statsData); @@ -244,8 +243,7 @@ private ColumnStatistics constructColumnStatsFromInput() } statsData.setDecimalStats(decimalStats); statsObj.setStatsData(statsData); - } else if (columnType.equalsIgnoreCase("date") - || columnType.equalsIgnoreCase("timestamp")) { + } else if (columnType.equalsIgnoreCase("date")) { DateColumnStatsData dateStats = new DateColumnStatsData(); Map mapProp = work.getMapProp(); for (Entry entry : mapProp.entrySet()) {