diff --git ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/AbstractJoinTaskDispatcher.java ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/AbstractJoinTaskDispatcher.java index a3a7f42ef1..09ad0bec3d 100644 --- ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/AbstractJoinTaskDispatcher.java +++ ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/AbstractJoinTaskDispatcher.java @@ -169,7 +169,7 @@ public Object dispatch(Node nd, Stack stack, Object... nodeOutputs) // get the list of task List> taskList = ((ConditionalTask) currTask).getListTasks(); for (Task tsk : taskList) { - if (tsk.isMapRedTask()) { + if (tsk instanceof MapRedTask) { Task newTask = this.processCurrentTask((MapRedTask) tsk, ((ConditionalTask) currTask), physicalContext.getContext()); walkerCtx.addToDispatchList(newTask);