commit 4f1cd26ce3eb4d95efb8a0dc2bec7e03b360202c
author Hari Subramaniyan <harisankar@apache.org> Sat Jul 30 22:25:29 2016 -0700
committer Hari Subramaniyan <harisankar@apache.org> Sat Jul 30 22:25:29 2016 -0700
tree 413f24043615de01225fd54d7d276888882088c5
parent 034c9821b496f0b182fd7e3d967d421580c0f23d

HIVE-14363: bucketmap inner join query fails due to NullPointerException in some cases (Hari Subramaniyan, reviewed by Matt McCline)

ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java

diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java
index e8ccbc4..0886c0e 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java
@@ -369,9 +369,10 @@
     // this sets up the map operator contexts correctly
     mapOp.initializeContexts();
     Deserializer deserializer = mapOp.getCurrentDeserializer();
+    // deserializer is null in case of VectorMapOperator
     KeyValueReader reader =
       new KeyValueInputMerger(kvReaderList, deserializer,
-          new ObjectInspector[] { deserializer.getObjectInspector() }, mapOp
+          new ObjectInspector[] { deserializer == null ? null : deserializer.getObjectInspector() }, mapOp
           .getConf()
           .getSortCols());
     return reader;