HIVE-2929 race condition in DAG execute tasks for hive (Namit Jain vi…

…a Siying Dong) git-svn-id: https://svn.apache.org/repos/asf/hive/trunk@1310619 13f79535-47bb-0310-9956-ffa450edef68
apache · Apr 6, 2012 · 012cf42 · 012cf42
1 parent fedb2ab
commit 012cf42
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 3 deletions.
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/Driver.java b/ql/src/java/org/apache/hadoop/hive/ql/Driver.java
@@ -1104,13 +1104,11 @@ public int execute() throws CommandNeedRetryException {
       SessionState.get().setLocalMapRedErrors(new HashMap<String, List<String>>());
 
       // Add root Tasks to runnable
-
       for (Task<? extends Serializable> tsk : plan.getRootTasks()) {
         driverCxt.addToRunnable(tsk);
       }
 
       // Loop while you either have tasks running, or tasks queued up
-
       while (running.size() != 0 || runnable.peek() != null) {
         // Launch upto maxthreads tasks
         while (runnable.peek() != null && running.size() < maxthreads) {

diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/HadoopJobExecHelper.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/HadoopJobExecHelper.java
@@ -403,7 +403,6 @@ private MapRedStats progress(ExecDriverTaskHandle th) throws IOException {
     MapRedStats mapRedStats = new MapRedStats(numMap, numReduce, cpuMsec, success, rj.getID().toString());
     mapRedStats.setCounters(ctrs);
 
-    this.task.setDone();
     // update based on the final value of the counters
     updateCounters(ctrs, rj);