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)
