hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From harisan...@apache.org
Subject hive git commit: HIVE-14363: bucketmap inner join query fails due to NullPointerException in some cases (Hari Subramaniyan, reviewed by Matt McCline)
Date Sun, 31 Jul 2016 05:27:23 GMT
Repository: hive
Updated Branches:
  refs/heads/branch-2.1 cb65a3a8b -> d50cdf74c


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


Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/d50cdf74
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/d50cdf74
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/d50cdf74

Branch: refs/heads/branch-2.1
Commit: d50cdf74c25774635863b76bac8e4d6721dff92f
Parents: cb65a3a
Author: Hari Subramaniyan <harisankar@apache.org>
Authored: Sat Jul 30 22:25:29 2016 -0700
Committer: Hari Subramaniyan <harisankar@apache.org>
Committed: Sat Jul 30 22:27:10 2016 -0700

----------------------------------------------------------------------
 .../org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/d50cdf74/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 b8ecf89..1e92f0a 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
@@ -361,9 +361,10 @@ public class MapRecordProcessor extends RecordProcessor {
     // 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;


Mime
View raw message