Skip to content

Commit

Permalink
Merge branch 'prettier-fallback-reason' of github.com:andygrove/dataf…
Browse files Browse the repository at this point in the history
…usion-comet into prettier-fallback-reason
  • Loading branch information
andygrove committed Jul 11, 2024
2 parents ef1e78f + bf60ec7 commit 103d12a
Show file tree
Hide file tree
Showing 3 changed files with 1 addition and 8 deletions.
2 changes: 1 addition & 1 deletion docs/source/user-guide/configs.md
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@ Comet provides the following configuration settings.
| spark.comet.exec.shuffle.enabled | Whether to enable Comet native shuffle. By default, this config is false. Note that this requires setting 'spark.shuffle.manager' to 'org.apache.spark.sql.comet.execution.shuffle.CometShuffleManager'. 'spark.shuffle.manager' must be set before starting the Spark application and cannot be changed during the application. | false |
| spark.comet.exec.shuffle.mode | The mode of Comet shuffle. This config is only effective if Comet shuffle is enabled. Available modes are 'native', 'jvm', and 'auto'. 'native' is for native shuffle which has best performance in general. 'jvm' is for jvm-based columnar shuffle which has higher coverage than native shuffle. 'auto' is for Comet to choose the best shuffle mode based on the query plan. By default, this config is 'jvm'. | jvm |
| spark.comet.explain.verbose.enabled | When this setting is enabled, Comet will provide a verbose tree representation of the extended information. | false |
| spark.comet.explainFallback.enabled | When this setting is enabled, Comet will provide logging explaining the reason(s) why a query stage cannot be executed natively. | false |
| spark.comet.explainFallback.enabled | When this setting is enabled, Comet will provide logging explaining the reason(s) why a query stage cannot be executed natively. Set this to false to reduce the amount of logging. | true |
| spark.comet.memory.overhead.factor | Fraction of executor memory to be allocated as additional non-heap memory per executor process for Comet. Default value is 0.2. | 0.2 |
| spark.comet.memory.overhead.min | Minimum amount of additional memory to be allocated per executor process for Comet, in MiB. | 402653184b |
| spark.comet.nativeLoadRequired | Whether to require Comet native library to load successfully when Comet is enabled. If not, Comet will silently fallback to Spark when it fails to load the native lib. Otherwise, an error will be thrown and the Spark job will be aborted. | false |
Expand Down
6 changes: 0 additions & 6 deletions native/rustfmt.toml
Original file line number Diff line number Diff line change
Expand Up @@ -17,9 +17,3 @@

edition = "2021"
max_width = 100

reorder_imports = true
reorder_modules = true

# this feature is only available in nightly
#group_imports = "StdExternalCrate"
Original file line number Diff line number Diff line change
Expand Up @@ -812,7 +812,6 @@ class CometSparkSessionExtensions
// Broadcast exchange exec is transformed by the parent node. We include
// this case specially here so we do not add a misleading 'info' message
case _: BroadcastExchangeExec => op
case _: AQEShuffleReadExec => op
case _: CometExec | _: CometBroadcastExchangeExec | _: CometShuffleExchangeExec => op
case o =>
withInfo(o, s"${o.nodeName} is not supported")
Expand Down

0 comments on commit 103d12a

Please sign in to comment.