diff --git common/src/java/org/apache/hadoop/hive/conf/HiveConf.java common/src/java/org/apache/hadoop/hive/conf/HiveConf.java index c61d95b..c868d2f 100644 --- common/src/java/org/apache/hadoop/hive/conf/HiveConf.java +++ common/src/java/org/apache/hadoop/hive/conf/HiveConf.java @@ -415,7 +415,6 @@ HIVEJOINEMITINTERVAL("hive.join.emit.interval", 1000), HIVEJOINCACHESIZE("hive.join.cache.size", 25000), HIVEMAPJOINBUCKETCACHESIZE("hive.mapjoin.bucket.cache.size", 100), - HIVEMAPJOINROWSIZE("hive.mapjoin.size.key", 10000), HIVEMAPJOINCACHEROWS("hive.mapjoin.cache.numrows", 25000), HIVEGROUPBYMAPINTERVAL("hive.groupby.mapaggr.checkinterval", 100000), HIVEMAPAGGRHASHMEMORY("hive.map.aggr.hash.percentmemory", (float) 0.5), diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/AbstractMapJoinOperator.java ql/src/java/org/apache/hadoop/hive/ql/exec/AbstractMapJoinOperator.java index cb9b875..00e4158 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/AbstractMapJoinOperator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/AbstractMapJoinOperator.java @@ -53,7 +53,6 @@ protected transient List[] joinKeysStandardObjectInspectors; protected transient byte posBigTable = -1; // one of the tables that is not in memory - transient int mapJoinRowsKey; // rows for a given key protected transient RowContainer> emptyList = null; @@ -104,9 +103,6 @@ protected void initializeOp(Configuration hconf) throws HiveException { !hasFilter(posBigTable), reporter); storage[posBigTable] = bigPosRC; - mapJoinRowsKey = HiveConf.getIntVar(hconf, - HiveConf.ConfVars.HIVEMAPJOINROWSIZE); - List structFields = ((StructObjectInspector) outputObjInspector) .getAllStructFieldRefs(); if (conf.getOutputColumnNames().size() < structFields.size()) { diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/HashTableSinkOperator.java ql/src/java/org/apache/hadoop/hive/ql/exec/HashTableSinkOperator.java index 3e3e220..fb6ecb4 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/HashTableSinkOperator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/HashTableSinkOperator.java @@ -70,7 +70,6 @@ protected transient List[] joinKeysStandardObjectInspectors; protected transient int posBigTableAlias = -1; // one of the tables that is not in memory - transient int mapJoinRowsKey; // rows for a given key protected transient RowContainer> emptyList = null;