Author: gunther
Date: Fri Sep 5 02:17:37 2014
New Revision: 1622596
URL: http://svn.apache.org/r1622596
Log:
HIVE-7994: BMJ test fails on tez (Gunther Hagleitner)
Modified:
hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/MapJoinOperator.java
hive/branches/tez/ql/src/test/results/clientpositive/tez/tez_bmj_schema_evolution.q.out
Modified:
hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/MapJoinOperator.java
URL:
http://svn.apache.org/viewvc/hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/MapJoinOperator.java?rev=1622596&r1=1622595&r2=1622596&view=diff
==============================================================================
---
hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/MapJoinOperator.java
(original)
+++
hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/MapJoinOperator.java
Fri Sep 5 02:17:37 2014
@@ -104,6 +104,8 @@ public class MapJoinOperator extends Abs
cache = ObjectCacheFactory.getCache(hconf);
loader = HashTableLoaderFactory.getLoader(hconf);
+ hashMapRowGetters = null;
+
mapJoinTables = (MapJoinTableContainer[]) cache.retrieve(tableKey);
mapJoinTableSerdes = (MapJoinTableContainerSerDe[])
cache.retrieve(serdeKey);
hashTblInitedOnce = true;
@@ -237,7 +239,7 @@ public class MapJoinOperator extends Abs
firstRow = false;
}
- alias = (byte)tag;
+ alias = (byte) tag;
if (hashMapRowGetters == null) {
hashMapRowGetters = new ReusableGetAdaptor[mapJoinTables.length];
MapJoinKey refKey = getRefKey(alias);
Modified:
hive/branches/tez/ql/src/test/results/clientpositive/tez/tez_bmj_schema_evolution.q.out
URL:
http://svn.apache.org/viewvc/hive/branches/tez/ql/src/test/results/clientpositive/tez/tez_bmj_schema_evolution.q.out?rev=1622596&r1=1622595&r2=1622596&view=diff
==============================================================================
---
hive/branches/tez/ql/src/test/results/clientpositive/tez/tez_bmj_schema_evolution.q.out
(original)
+++
hive/branches/tez/ql/src/test/results/clientpositive/tez/tez_bmj_schema_evolution.q.out
Fri Sep 5 02:17:37 2014
@@ -1,6 +1,7 @@
PREHOOK: query: create table test (key int, value string) partitioned by (p
int) clustered by (key) into 2 buckets stored as textfile
PREHOOK: type: CREATETABLE
PREHOOK: Output: database:default
+PREHOOK: Output: default@test
POSTHOOK: query: create table test (key int, value string) partitioned by (p
int) clustered by (key) into 2 buckets stored as textfile
POSTHOOK: type: CREATETABLE
POSTHOOK: Output: database:default
@@ -8,6 +9,7 @@ POSTHOOK: Output: default@test
PREHOOK: query: create table test1 (key int, value string) stored as textfile
PREHOOK: type: CREATETABLE
PREHOOK: Output: database:default
+PREHOOK: Output: default@test1
POSTHOOK: query: create table test1 (key int, value string) stored as textfile
POSTHOOK: type: CREATETABLE
POSTHOOK: Output: database:default
