Index: ql/src/java/org/apache/hadoop/hive/ql/exec/ConditionalTask.java =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/exec/ConditionalTask.java (revision 909965) +++ ql/src/java/org/apache/hadoop/hive/ql/exec/ConditionalTask.java (working copy) @@ -85,7 +85,9 @@ console.printInfo(ExecDriver.getJobEndMsg("" + Utilities.randGen.nextInt()) + ", job is filtered out (removed at runtime)."); - driverContext.incCurJobNo(1); + if(tsk.isMapRedTask()) { + driverContext.incCurJobNo(1); + } if (tsk.getChildTasks() != null) { for (Task child : tsk.getChildTasks()) { child.parentTasks.remove(tsk);