XiDuo You created SPARK-37528:
---------------------------------

             Summary: Support reorder tasks during scheduling by shuffle 
partition size in AQE
                 Key: SPARK-37528
                 URL: https://issues.apache.org/jira/browse/SPARK-37528
             Project: Spark
          Issue Type: New Feature
          Components: Spark Core, SQL
    Affects Versions: 3.3.0
            Reporter: XiDuo You


Reorder tasks by input size can save the whole stage execution time. Let's say 
we have one stage with 4 tasks and the `defaultParallelism` is 2 and the 4 
tasks have differnt execution time with [1s, 3s, 2s, 4s].
 * in normal the execution time of the stage is: 7s
 * after reorder the tasks, the execution time of the stage is: 5s


a new config `spark.scheduler.reorderTasks.enabled` to decide if we allow to 
reorder tasks.

 



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org
For additional commands, e-mail: issues-h...@spark.apache.org

Reply via email to