-
Notifications
You must be signed in to change notification settings - Fork 447
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[GLUTEN-3049] Introduce a local property to control the usage of gluten at thread level #3357
Conversation
Run Gluten Clickhouse CI |
@PHILO-HE Please help me with a review ? |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I'm assuming end user needs to get a sparkContext to set this local property to control the usage of gluten. Another thought, is it workable to you in practice by just dynamically setting spark.gluten.enabled
? It looks a context level controlling.
SET spark.gluten.enabled=false;
SELECT count(*) from example;
SET spark.gluten.enabled=true;
SELECT count(*) from example;
...ickhouse/src/test/scala/io/glutenproject/execution/GlutenClickHouseTPCHParquetAQESuite.scala
Outdated
Show resolved
Hide resolved
In my case, all users will shared the same context. |
Run Gluten Clickhouse CI |
shims/common/src/main/scala/io/glutenproject/GlutenConfig.scala
Outdated
Show resolved
Hide resolved
...ickhouse/src/test/scala/io/glutenproject/execution/GlutenClickHouseTPCHParquetAQESuite.scala
Outdated
Show resolved
Hide resolved
gluten-core/src/main/scala/io/glutenproject/utils/QueryPlanSelector.scala
Outdated
Show resolved
Hide resolved
Just modified the title. It looks not that correct to use "statement level". Please feel free to re-modify it if you have a better expression. |
Run Gluten Clickhouse CI |
shims/common/src/main/scala/io/glutenproject/GlutenConfig.scala
Outdated
Show resolved
Hide resolved
Run Gluten Clickhouse CI |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
A few comments. Thanks!
gluten-core/src/main/scala/io/glutenproject/utils/QueryPlanSelector.scala
Outdated
Show resolved
Hide resolved
gluten-core/src/main/scala/io/glutenproject/utils/QueryPlanSelector.scala
Outdated
Show resolved
Hide resolved
...ickhouse/src/test/scala/io/glutenproject/execution/GlutenClickHouseTPCHParquetAQESuite.scala
Outdated
Show resolved
Hide resolved
shims/common/src/main/scala/io/glutenproject/GlutenConfig.scala
Outdated
Show resolved
Hide resolved
...ickhouse/src/test/scala/io/glutenproject/execution/GlutenClickHouseTPCHParquetAQESuite.scala
Outdated
Show resolved
Hide resolved
Run Gluten Clickhouse CI |
Run Gluten Clickhouse CI |
1 similar comment
Run Gluten Clickhouse CI |
Run Gluten Clickhouse CI |
@@ -63,3 +63,9 @@ spark.driver.extraClassPath ${GLUTEN_HOME}/package/target/gluten-<>-jar-with- | |||
spark.executor.extraClassPath ${GLUTEN_HOME}/package/target/gluten-<>-jar-with-dependencies.jar | |||
###### | |||
``` | |||
|
|||
Additionally, you can control the configurations of gluten at thread level by local property. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Assume users have to get a spark context to set local property. Could you add more details for how to set such property? Thanks!
gluten-ut/spark32/src/test/scala/org/apache/spark/sql/execution/FallbackStrategiesSuite.scala
Outdated
Show resolved
Hide resolved
Run Gluten Clickhouse CI |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Looks good! @zhztheplayer, do you have any comment? Thanks!
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks!
…n at thread level
===== Performance report for TPCH SF2000 with Velox backend, for reference only ====
|
What changes were proposed in this pull request?
Support local properties to controller whole query fallback
How was this patch tested?
Test by ut