Uploaded image for project: 'Hive'
  1. Hive
  2. HIVE-21111

ConditionalTask cannot be cast to MapRedTask

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 2.1.1, 2.3.4, 3.1.1
    • Fix Version/s: 4.0.0
    • Component/s: Physical Optimizer
    • Labels:
      None

      Description

      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.

        Attachments

        1. HIVE-21111.1.patch
          1.0 kB
          zhuwei

          Issue Links

            Activity

              People

              • Assignee:
                qunyan zhuwei
                Reporter:
                qunyan zhuwei
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: