Index: conf/hive-default.xml.template =================================================================== --- conf/hive-default.xml.template (revision 1357734) +++ conf/hive-default.xml.template (working copy) @@ -1328,5 +1328,22 @@ + + hive.querylog.location + /tmp/${user.name} + + Location of Hive run time structured log file + + + + + hive.querylog.enable.plan.progress + true + + Whether to log the plan's progress every time a job's progress is checked. + These logs are written to the location specified by hive.querylog.location + + + Index: common/src/java/org/apache/hadoop/hive/conf/HiveConf.java =================================================================== --- common/src/java/org/apache/hadoop/hive/conf/HiveConf.java (revision 1357734) +++ common/src/java/org/apache/hadoop/hive/conf/HiveConf.java (working copy) @@ -382,6 +382,9 @@ //Location of Hive run time structured log file HIVEHISTORYFILELOC("hive.querylog.location", "/tmp/" + System.getProperty("user.name")), + // Whether to log the plan's progress every time a job's progress is checked + HIVE_LOG_INCREMENTAL_PLAN_PROGRESS("hive.querylog.enable.plan.progress", true), + // Default serde and record reader for user scripts HIVESCRIPTSERDE("hive.script.serde", "org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe"), HIVESCRIPTRECORDREADER("hive.script.recordreader", Index: ql/src/java/org/apache/hadoop/hive/ql/exec/HadoopJobExecHelper.java =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/exec/HadoopJobExecHelper.java (revision 1357734) +++ ql/src/java/org/apache/hadoop/hive/ql/exec/HadoopJobExecHelper.java (working copy) @@ -355,8 +355,10 @@ ss.getHiveHistory().setTaskCounters(SessionState.get().getQueryId(), getId(), ctrs); ss.getHiveHistory().setTaskProperty(SessionState.get().getQueryId(), getId(), Keys.TASK_HADOOP_PROGRESS, output); - ss.getHiveHistory().progressTask(SessionState.get().getQueryId(), this.task); - this.callBackObj.logPlanProgress(ss); + if (ss.getConf().getBoolVar(HiveConf.ConfVars.HIVE_LOG_INCREMENTAL_PLAN_PROGRESS)) { + ss.getHiveHistory().progressTask(SessionState.get().getQueryId(), this.task); + this.callBackObj.logPlanProgress(ss); + } } console.printInfo(output); lastReport = report;