diff --git ql/src/java/org/apache/hadoop/hive/ql/optimizer/ReduceSinkDeDuplication.java ql/src/java/org/apache/hadoop/hive/ql/optimizer/ReduceSinkDeDuplication.java index 77c50b0..11ed929 100644 --- ql/src/java/org/apache/hadoop/hive/ql/optimizer/ReduceSinkDeDuplication.java +++ ql/src/java/org/apache/hadoop/hive/ql/optimizer/ReduceSinkDeDuplication.java @@ -412,16 +412,20 @@ private boolean backTrackColumnNames( if(partitionCols != null) { for (ExprNodeDesc desc : partitionCols) { List cols = desc.getCols(); - for(String col : cols) { - columnMapping.put(col, col); + if ( cols != null ) { + for(String col : cols) { + columnMapping.put(col, col); + } } } } if(reduceKeyCols != null) { for (ExprNodeDesc desc : reduceKeyCols) { List cols = desc.getCols(); - for(String col : cols) { - columnMapping.put(col, col); + if ( cols != null ) { + for(String col : cols) { + columnMapping.put(col, col); + } } } }