You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@arrow.apache.org by ho...@apache.org on 2021/08/28 05:07:52 UTC
[arrow-datafusion] branch master updated: Update plan_query_stages
doc (#951)
This is an automated email from the ASF dual-hosted git repository.
houqp pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/arrow-datafusion.git
The following commit(s) were added to refs/heads/master by this push:
new 6ccc54b Update plan_query_stages doc (#951)
6ccc54b is described below
commit 6ccc54bdd4f2888c8fc09234b0c5f5223d514f75
Author: rdettai <rd...@gmail.com>
AuthorDate: Sat Aug 28 07:07:45 2021 +0200
Update plan_query_stages doc (#951)
I don't think the result of `DistributedPlanner.plan_query_stages()` can be an empty vector: if the plan does not need to be sliced it is still wrapped into a `ShuffleWriterExec` and returned as such.
---
ballista/rust/scheduler/src/planner.rs | 2 --
1 file changed, 2 deletions(-)
diff --git a/ballista/rust/scheduler/src/planner.rs b/ballista/rust/scheduler/src/planner.rs
index 05025f2..6ed6fb6 100644
--- a/ballista/rust/scheduler/src/planner.rs
+++ b/ballista/rust/scheduler/src/planner.rs
@@ -57,8 +57,6 @@ 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.
- ///
- /// Returns an empty vector if the execution_plan doesn't need to be sliced into several stages.
pub fn plan_query_stages(
&mut self,
job_id: &str,