You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Is your feature request related to a problem or challenge? Please describe what you are trying to do.
The Ballista scheduler breaks a query down into stages based on changes in partitioning in the plan, where each stage is broken down into tasks that can be executed concurrently.
Rather than trying to run all the partitions at once, Ballista executors process n concurrent tasks at a time and then request new tasks from the scheduler.
This approach would help DataFusion scale better and it would be ideal to use the same scheduler to scale across cores in DataFusion and across nodes in Ballista.
Describe the solution you'd like
Implement an extensible scheduler in DataFusion and have Ballista extend it to provide distributed execution.
I am not sure if this is tracking anything actionable and hasn't had any updates in a few years, so closing it. Please feel free to reopen if i got that wrong
Activity
Adds optional serde support to datafusion-proto (#2892)
Merge pull request #64 from waitingkuo/issue-3002
alamb commentedon Jun 11, 2023
I am not sure if this is tracking anything actionable and hasn't had any updates in a few years, so closing it. Please feel free to reopen if i got that wrong