diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/Task.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/Task.java index e584e6e..8c39fb2 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/Task.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/Task.java @@ -57,7 +57,7 @@ public transient TaskHandle taskHandle; protected transient boolean started; protected transient boolean initialized; - protected transient boolean isdone; + protected transient volatile boolean isdone; protected transient boolean queued; protected transient HiveConf conf; protected transient Hive db; @@ -349,6 +349,7 @@ public boolean isRunnable() { if (parentTasks != null) { for (Task parent : parentTasks) { if (!parent.done()) { + LOG.debug("Task " + this + " cannot run because parent " + parent + " isn't done."); isrunnable = false; break; }