thinkharderdev commented on code in PR #59:
URL: https://github.com/apache/arrow-ballista/pull/59#discussion_r889978574
##########
ballista/rust/scheduler/src/planner.rs:
##########
@@ -59,15 +58,14 @@ impl DistributedPlanner {
/// Returns a vector of ExecutionPlans, where the root node is a
[ShuffleWriterExec].
/// Plans that depend on the input of other plans will have leaf nodes of
type [UnresolvedShuffleExec].
/// A [ShuffleWriterExec] is created whenever the partitioning changes.
- pub async fn plan_query_stages<'a>(
+ pub fn plan_query_stages<'a>(
Review Comment:
I think it was doing that at tone time but the implementation now is not
doing IO so I changed it back to sync.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
