[FLINK-33742] Hybrid Shuffle should work well with Adaptive Query Execution

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.19.0
• Component/s: Runtime / Coordination, Runtime / Network
• Labels: Umbrella
• Assignee: Unassigned
• Reporter: Yuxin Tan
• Created: 05/Dec/23 04:12
• Updated: 05/Dec/23 05:13

Description

At present, Hybrid Shuffle and Adaptive Query Execution (AQE), which includes features such as Dynamic Partition Pruning (DPP), Runtime Filter, and Adaptive Batch Scheduler, are not fully compatible. While they can be used concurrently at the same time, the activation of AQE inhibits the key capability of Hybrid Shuffle to perform simultaneous reading and writing. This limitation arises because AQE dictates that downstream tasks may only initiate once upstream tasks have finished, a requirement that is inconsistent with the simultaneous read-write process facilitated by Hybrid Shuffle. In addition, Hybrid Shuffle will restart the whole job when failover, which is also an essential issue for production usage.

To harness the full potential of Hybrid Shuffle and AQE, it is essential to refine their integration. By doing so, we can capitalize on each feature's distinct advantages and enhance overall system performance.

Sub-Tasks

• Support consuming multiple subpartitions on a single channel: Closed
• Hybrid shuffle avoids restarting the whole job when failover: Open
• Dynamically choose hybrid shuffle or AQE in a job level: Open
• More precise dynamic selection of Hybrid Shuffle or AQE: Open