Index: conf/hive-default.xml.template =================================================================== --- conf/hive-default.xml.template (revision 1357734) +++ conf/hive-default.xml.template (working copy) @@ -1328,5 +1328,12 @@ + + hive.log.incremental.plan.progress + true> + + Whether to log the plan's progress every time a job's progress is checked + + 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) @@ -590,6 +590,9 @@ // outputs are ready HIVE_MULTI_INSERT_MOVE_TASKS_SHARE_DEPENDENCIES( "hive.multi.insert.move.tasks.share.dependencies", false), + + // Whether to log the plan's progress every time a job's progress is checked + HIVE_LOG_INCREMENTAL_PLAN_PROGRESS("hive.log.incremental.plan.progress", true), ; public final String varname; 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;