You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@datafusion.apache.org by ag...@apache.org on 2024/12/05 15:59:04 UTC
(datafusion-ballista) branch main updated: Fix one example in tunning guide (#1145)
This is an automated email from the ASF dual-hosted git repository.
agrove pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion-ballista.git
The following commit(s) were added to refs/heads/main by this push:
new 46cf5d29 Fix one example in tunning guide (#1145)
46cf5d29 is described below
commit 46cf5d29a6423c08972e320dc258868c1ea0403a
Author: Marko Milenković <mi...@users.noreply.github.com>
AuthorDate: Thu Dec 5 15:59:00 2024 +0000
Fix one example in tunning guide (#1145)
---
docs/source/user-guide/tuning-guide.md | 18 +++++++++++++-----
1 file changed, 13 insertions(+), 5 deletions(-)
diff --git a/docs/source/user-guide/tuning-guide.md b/docs/source/user-guide/tuning-guide.md
index b1b61240..22955b44 100644
--- a/docs/source/user-guide/tuning-guide.md
+++ b/docs/source/user-guide/tuning-guide.md
@@ -32,7 +32,7 @@ For example, if there is a table "customer" that consists of 200 Parquet files,
200 partitions and the table scan and certain subsequent operations will also have 200 partitions. Conversely, if the
table only has a single Parquet file then there will be a single partition and the work will not be able to scale even
if the cluster has resource available. Ballista supports repartitioning within a query to improve parallelism.
-The configuration setting `ballista.shuffle.partitions`can be set to the desired number of partitions. This is
+The configuration setting `datafusion.execution.target_partitions`can be set to the desired number of partitions. This is
currently a global setting for the entire context. The default value for this setting is 16.
Note that Ballista will never decrease the number of partitions based on this setting and will only repartition if
@@ -41,11 +41,17 @@ the source operation has fewer partitions than this setting.
Example: Setting the desired number of shuffle partitions when creating a context.
```rust
-let config = BallistaConfig::builder()
- .set("ballista.shuffle.partitions", "200")
- .build()?;
+use ballista::extension::{SessionConfigExt, SessionContextExt};
-let ctx = BallistaContext::remote("localhost", 50050, &config).await?;
+let session_config = SessionConfig::new_with_ballista()
+ .with_target_partitions(200);
+
+let state = SessionStateBuilder::new()
+ .with_default_features()
+ .with_config(session_config)
+ .build();
+
+let ctx: SessionContext = SessionContext::remote_with_state(&url,state).await?;
```
## Configuring Executor Concurrency Levels
@@ -75,6 +81,8 @@ processes. The default is `pull-based`.
The scheduler provides a REST API for monitoring jobs. See the
[scheduler documentation](scheduler.md) for more information.
+> This is optional scheduler feature which should be enabled with rest-api feature
+
To download a query plan in dot format from the scheduler, submit a request to the following API endpoint
```
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@datafusion.apache.org
For additional commands, e-mail: commits-help@datafusion.apache.org