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

Physical plan node Coalesce should be able to handle UnsafeRow

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Minor
    • Resolution: Fixed
    • 1.6.0
    • 1.6.0
    • SQL
    • None

    Description

      The following PySpark snippet shows the problem:

      >>> sqlContext.range(10).selectExpr('id AS a').coalesce(1).explain(True)
      ...
      == Physical Plan ==
      Coalesce 1
       ConvertToSafe
        TungstenProject [id#3L AS a#4L]
         Scan PhysicalRDD[id#3L]
      

      The ConvertToSafe is unnecessary.

      Attachments

        Activity

          People

            lian cheng Cheng Lian
            lian cheng Cheng Lian
            Josh Rosen Josh Rosen
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: