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,