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 <[email protected]>
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,
