Index: ql/src/java/org/apache/hadoop/hive/ql/exec/HadoopJobExecHelper.java =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/exec/HadoopJobExecHelper.java (revision 1098811) +++ ql/src/java/org/apache/hadoop/hive/ql/exec/HadoopJobExecHelper.java (working copy) @@ -191,7 +191,7 @@ long numFiles = ctrs.getCounter(ProgressCounter.CREATED_FILES); long upperLimit = HiveConf.getLongVar(job, HiveConf.ConfVars.MAXCREATEDFILES); if (numFiles > upperLimit) { - errMsg.append("total number of created files exceeds ").append(upperLimit); + errMsg.append("total number of created files now is " + numFiles + ", exceeds ").append(upperLimit); return true; } return this.callBackObj.checkFatalErrors(ctrs, errMsg); @@ -279,7 +279,7 @@ Counters ctrs = th.getCounters(); - if (fatal = this.callBackObj.checkFatalErrors(ctrs, errMsg)) { + if (fatal = checkFatalErrors(ctrs, errMsg)) { console.printError("[Fatal Error] " + errMsg.toString() + ". Killing the job."); rj.killJob(); continue;