diff --git common/src/java/org/apache/hadoop/hive/conf/HiveConf.java common/src/java/org/apache/hadoop/hive/conf/HiveConf.java index 55be50d..8deb9c5 100644 --- common/src/java/org/apache/hadoop/hive/conf/HiveConf.java +++ common/src/java/org/apache/hadoop/hive/conf/HiveConf.java @@ -548,7 +548,7 @@ HIVECONVERTJOINNOCONDITIONALTASK("hive.auto.convert.join.noconditionaltask", true), HIVECONVERTJOINNOCONDITIONALTASKTHRESHOLD("hive.auto.convert.join.noconditionaltask.size", 10000000L), - HIVECONVERTJOINUSENONSTAGED("hive.auto.convert.join.use.nonstaged", true), + HIVECONVERTJOINUSENONSTAGED("hive.auto.convert.join.use.nonstaged", false), HIVESKEWJOINKEY("hive.skewjoin.key", 100000), HIVESKEWJOINMAPJOINNUMMAPTASK("hive.skewjoin.mapjoin.map.tasks", 10000), HIVESKEWJOINMAPJOINMINSPLIT("hive.skewjoin.mapjoin.min.split", 33554432L), //32M diff --git conf/hive-default.xml.template conf/hive-default.xml.template index 3c3df43..0dac616 100644 --- conf/hive-default.xml.template +++ conf/hive-default.xml.template @@ -881,7 +881,7 @@ hive.auto.convert.join.use.nonstaged - true + false For conditional joins, if input stream from a small alias can be directly applied to join operator without filtering or projection, the alias need not to be pre-staged in distributed cache via mapred local task. Currently, this is not working with vectorization or tez execution engine.