diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/MapJoinOperator.java ql/src/java/org/apache/hadoop/hive/ql/exec/MapJoinOperator.java index 99b937c..ef0c055 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/MapJoinOperator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/MapJoinOperator.java @@ -104,6 +104,8 @@ protected void initializeOp(Configuration hconf) throws HiveException { 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 void processOp(Object row, int tag) throws HiveException { firstRow = false; } - alias = (byte)tag; + alias = (byte) tag; if (hashMapRowGetters == null) { hashMapRowGetters = new ReusableGetAdaptor[mapJoinTables.length]; MapJoinKey refKey = getRefKey(alias); diff --git ql/src/test/results/clientpositive/tez/tez_bmj_schema_evolution.q.out ql/src/test/results/clientpositive/tez/tez_bmj_schema_evolution.q.out index 047ce3d..4682a05 100644 --- ql/src/test/results/clientpositive/tez/tez_bmj_schema_evolution.q.out +++ ql/src/test/results/clientpositive/tez/tez_bmj_schema_evolution.q.out @@ -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