hive-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Rui Li (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (HIVE-21111) ConditionalTask cannot be cast to MapRedTask
Date Mon, 25 Mar 2019 02:19:00 GMT

    [ https://issues.apache.org/jira/browse/HIVE-21111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16800361#comment-16800361
] 

Rui Li commented on HIVE-21111:
-------------------------------

[~qunyan] glad to know it helps. Closing this one.

> ConditionalTask cannot be cast to MapRedTask
> --------------------------------------------
>
>                 Key: HIVE-21111
>                 URL: https://issues.apache.org/jira/browse/HIVE-21111
>             Project: Hive
>          Issue Type: Bug
>          Components: Physical Optimizer
>    Affects Versions: 2.1.1, 3.1.1, 2.3.4
>            Reporter: zhuwei
>            Assignee: zhuwei
>            Priority: Major
>         Attachments: HIVE-21111.1.patch
>
>
> 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)

Mime
View raw message