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;