diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/ConditionalTask.java ql/src/java/org/apache/hadoop/hive/ql/exec/ConditionalTask.java index c2b058ae5f..fbefff511b 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/ConditionalTask.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/ConditionalTask.java @@ -106,8 +106,9 @@ private void resolveTask(DriverContext driverContext) throws HiveException { } } // resolved task - if (driverContext.addToRunnable(tsk)) { + if (DriverContext.isLaunchable(tsk)) { console.printInfo(tsk.getId() + " is selected by condition resolver."); + driverContext.addToRunnable(tsk); } } }