Skip to content

Commit 4a6804d

Browse files
committed
Update the wrong column name used
1 parent bce7d88 commit 4a6804d

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

ql/src/java/org/apache/hadoop/hive/ql/parse/ColumnStatsSemanticAnalyzer.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -212,22 +212,22 @@ protected static List<String> getColumnTypes(Table tbl, List<String> colNames) {
212212
colTypeMap.put(col.getName().toLowerCase(), col.getType());
213213
}
214214

215-
List<String> nonPrimColNames = new ArrayList<>();
215+
List<String> primColNames = new ArrayList<>();
216216
for (String colName : colNames) {
217217
String type = colTypeMap.get(colName.toLowerCase());
218218
if (type != null) {
219219
TypeInfo typeInfo = TypeInfoUtils.getTypeInfoFromTypeString(type);
220220
if (typeInfo.getCategory() != ObjectInspector.Category.PRIMITIVE) {
221221
logTypeWarning(colName, type);
222222
} else {
223-
nonPrimColNames.add(colName);
223+
primColNames.add(colName);
224224
colTypes.add(type);
225225
}
226226
}
227227
}
228228

229229
colNames.clear();
230-
colNames.addAll(nonPrimColNames);
230+
colNames.addAll(primColNames);
231231
return colTypes;
232232
}
233233

0 commit comments

Comments
 (0)