-
Notifications
You must be signed in to change notification settings - Fork 444
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-6876] Support Spark-352 #7138
Conversation
Run Gluten Clickhouse CI |
e844f5d
to
2497695
Compare
Run Gluten Clickhouse CI |
@@ -107,7 +107,7 @@ class ColumnarShuffleManager(conf: SparkConf) extends ShuffleManager with Loggin | |||
metrics, | |||
shuffleExecutorComponents) | |||
case other: BaseShuffleHandle[K @unchecked, V @unchecked, _] => | |||
new SortShuffleWriter(other, mapId, context, shuffleExecutorComponents) | |||
new SortShuffleWriter(other, mapId, context, _, shuffleExecutorComponents) |
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.
Does this mean that gluten will not guarantee spark minor version compatibility?
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.
Hi @wForget,
Not guaranteed for all minor versions indeed. Actually it's the same for Spark 32 & 3.3 & 3.4. It's only tested with the latest minor release.
The issue is mostly due to the shim layer design, and the CI/CD resources are also not enough for so many small versions.
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 see, thank you.
Run Gluten Clickhouse CI |
p: SparkPlan, | ||
reason: String, | ||
fallbackNodeToReason: mutable.HashMap[String, String]): Unit = { | ||
p.getTagValue(QueryPlan.OP_ID_TAG).foreach { |
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.
https://issues.apache.org/jira/browse/SPARK-48610
QueryPlan.OP_ID_TAG doesn't exist in spark 3.5.2+ / 4.0.0
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, there's also a minor change on sortshufflewriter, will move these changes to shim layer
Run Gluten Clickhouse CI |
2f439e6
to
7ce863d
Compare
Run Gluten Clickhouse CI |
3 similar comments
Run Gluten Clickhouse CI |
Run Gluten Clickhouse CI |
Run Gluten Clickhouse CI |
Run Gluten Clickhouse CI |
2 similar comments
Run Gluten Clickhouse CI |
Run Gluten Clickhouse CI |
Run Gluten Clickhouse CI |
Spark 3.5.3 is out https://spark.apache.org/news/spark-3-5-3-released.html, should we upgrade to 3.5.3? |
Yes, plan to submit one new patch for Spark-353 after this - actually there's not much change from 352 to 353 thanks, -yuan |
Run Gluten Clickhouse CI |
df34d44
to
a988a6b
Compare
let me try performance for ch backend, |
264ac93
to
6031293
Compare
Run Gluten Clickhouse CI |
6031293
to
082196c
Compare
Run Gluten Clickhouse CI |
Signed-off-by: Yuan Zhou <[email protected]>
Signed-off-by: Yuan Zhou <[email protected]>
Signed-off-by: Yuan Zhou <[email protected]>
Signed-off-by: Yuan Zhou <[email protected]>
Signed-off-by: Yuan Zhou <[email protected]>
Signed-off-by: Yuan Zhou <[email protected]>
Signed-off-by: Yuan Zhou <[email protected]>
Signed-off-by: Yuan Zhou <[email protected]>
Signed-off-by: Yuan Zhou <[email protected]>
Signed-off-by: Yuan Zhou <[email protected]>
Signed-off-by: Yuan Zhou <[email protected]>
Signed-off-by: Yuan Zhou <[email protected]>
Signed-off-by: Yuan Zhou <[email protected]>
Signed-off-by: Yuan Zhou <[email protected]>
Signed-off-by: Yuan Zhou <[email protected]>
Signed-off-by: Yuan Zhou <[email protected]>
Signed-off-by: Yuan Zhou <[email protected]>
082196c
to
6125e92
Compare
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.
LGTM
What changes were proposed in this pull request?
Support Spark 352
fixes #6876
How was this patch tested?
Pass GHA