Uploaded image for project: 'Spark'
  1. Spark
  2. SPARK-2895

Support mapPartitionsWithContext in Spark Java API

    XMLWordPrintableJSON

Details

    • New Feature
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • None
    • 1.2.0
    • Java API

    Description

      This is a requirement from Hive on Spark, mapPartitionsWithContext only exists in Spark Scala API, we expect to access from Spark Java API.
      For HIVE-7627, HIVE-7843, Hive operators which are invoked in mapPartitions closure need to get taskId.

      Attachments

        Issue Links

          blocks

          Bug - A problem which impairs or prevents the functions of the product. HIVE-7627 FSStatsPublisher does fit into Spark multi-thread task mode[Spark Branch]

          • Major - Major loss of function.
          • Resolved
          Is contained by

          Bug - A problem which impairs or prevents the functions of the product. SPARK-3543 Write TaskContext in Java and expose it through a static accessor

          • Critical - Crashes, loss of data, severe memory leak.
          • Resolved
          is depended upon by

          Sub-task - The sub-task of the issue HIVE-7843 orc_analyze.q fails due to random mapred.task.id in FileSinkOperator [Spark Branch]

          • Major - Major loss of function.
          • Resolved

          Epic - Created by Jira Software - do not edit or delete. Issue type for a big user story that needs to be broken down. SPARK-3145 Hive on Spark umbrella

          • Major - Major loss of function.
          • Resolved

          Improvement - An improvement or enhancement to an existing feature or task. HIVE-7292 Hive on Spark

          • Major - Major loss of function.
          • Resolved
          is related to

          Bug - A problem which impairs or prevents the functions of the product. HIVE-7627 FSStatsPublisher does fit into Spark multi-thread task mode[Spark Branch]

          • Major - Major loss of function.
          • Resolved
          links to

          Web Link https://github.com/apache/spark/pull/2194

          Activity

            People

              chengxiang li Chengxiang Li
              chengxiang li Chengxiang Li
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: