-
Notifications
You must be signed in to change notification settings - Fork 29k
[SPARK-54358][SDP][FOLLOWUP] Add tableIdentifierToPathString helper method for SDP checkpoint path construction
#53089
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
Conversation
| /** | ||
| * Converts a TableIdentifier to a path string by joining its name parts with the path separator. | ||
| */ | ||
| private def tableIdentifierToPathString(tableIdentifier: TableIdentifier): String = { |
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.
Please fix the corresponding test case to use this method too.
spark/sql/pipelines/src/test/scala/org/apache/spark/sql/pipelines/graph/SystemMetadataSuite.scala
Line 277 in 5222f1a
| val tableId = t.identifier.nameParts.mkString(Path.SEPARATOR) |
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.
In general, SystemMetadataSuite reimplements the path construction logic rather than relying on methods in SystemMetadata, to ensure that we'll catch any changes to the behavior if those methods change.
So my inclination is to avoid reusing this helper there for that reason, but I don't mind changing it if you feel strongly.
|
FYI, @sryza . For the follow-up PRs, the Apache Spark community uses As a result, you had better revise the remaining PR title, |
tableIdentifierToPathString always for SDP checkpoint path construction
dongjoon-hyun
left a comment
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.
+1, LGTM. Thank you, @sryza and @HyukjinKwon .
Merged to master/4.1 for Apache Spark 4.1.0.
tableIdentifierToPathString always for SDP checkpoint path constructiontableIdentifierToPathString helper method for SDP checkpoint path construction
… method for SDP checkpoint path construction ### What changes were proposed in this pull request? Followups from #53070 to improve code clarity. ### Why are the changes needed? Make sure the code for constructing SDP checkpoint directory paths is clear. ### Does this PR introduce _any_ user-facing change? No ### How was this patch tested? ### Was this patch authored or co-authored using generative AI tooling? Closes #53089 from sryza/collide-followups. Authored-by: Sandy Ryza <sandy.ryza@databricks.com> Signed-off-by: Dongjoon Hyun <dongjoon@apache.org> (cherry picked from commit 10d1b4c) Signed-off-by: Dongjoon Hyun <dongjoon@apache.org>
… method for SDP checkpoint path construction ### What changes were proposed in this pull request? Followups from apache#53070 to improve code clarity. ### Why are the changes needed? Make sure the code for constructing SDP checkpoint directory paths is clear. ### Does this PR introduce _any_ user-facing change? No ### How was this patch tested? ### Was this patch authored or co-authored using generative AI tooling? Closes apache#53089 from sryza/collide-followups. Authored-by: Sandy Ryza <sandy.ryza@databricks.com> Signed-off-by: Dongjoon Hyun <dongjoon@apache.org>
What changes were proposed in this pull request?
Followups from #53070 to improve code clarity.
Why are the changes needed?
Make sure the code for constructing SDP checkpoint directory paths is clear.
Does this PR introduce any user-facing change?
No
How was this patch tested?
Was this patch authored or co-authored using generative AI tooling?