Skip to content

Commit

Permalink
HIVE-2142. Jobs do not get killed even when they created too many fil…
Browse files Browse the repository at this point in the history
…es. (He Yongqiang via Ning Zhang)

git-svn-id: https://svn.apache.org/repos/asf/hive/trunk@1098907 13f79535-47bb-0310-9956-ffa450edef68
  • Loading branch information
Ning Zhang committed May 3, 2011
1 parent d81c126 commit 4782b32
Showing 1 changed file with 2 additions and 2 deletions.
Expand Up @@ -191,7 +191,7 @@ public boolean checkFatalErrors(Counters ctrs, StringBuilder errMsg) {
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 + ", which exceeds ").append(upperLimit);
return true;
}
return this.callBackObj.checkFatalErrors(ctrs, errMsg);
Expand Down Expand Up @@ -279,7 +279,7 @@ private boolean progress(ExecDriverTaskHandle th) throws IOException {

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;
Expand Down

0 comments on commit 4782b32

Please sign in to comment.