zhuwei created HIVE-21111: ----------------------------- Summary: ConditionalTask cannot be cast to MapRedTask Key: HIVE-21111 URL: https://issues.apache.org/jira/browse/HIVE-21111 Project: Hive Issue Type: Bug Reporter: zhuwei Assignee: zhuwei
We met error like this in our product environment: java.lang.ClassCastException: org.apache.hadoop.hive.ql.exec.ConditionalTask cannot be cast to org.apache.hadoop.hive.ql.exec.mr.MapRedTask at org.apache.hadoop.hive.ql.optimizer.physical.AbstractJoinTaskDispatcher.dispatch(AbstractJoinTaskDispatcher.java:173) There is a bug in function org.apache.hadoop.hive.ql.optimizer.physical.AbstractJoinTaskDispatcher.dispatch: if (tsk.isMapRedTask()) { Task<? extends Serializable> newTask = this.processCurrentTask((MapRedTask) tsk, ((ConditionalTask) currTask), physicalContext.getContext()); walkerCtx.addToDispatchList(newTask); } In the above code, when tsk is instance of ConditionalTask, tsk.isMapRedTask() still can be true, but it cannot be cast to MapRedTask. -- This message was sent by Atlassian JIRA (v7.6.3#76005)