-
Notifications
You must be signed in to change notification settings - Fork 2.3k
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
Spark: propagate snapshot properties for RewriteDataFiles and RewritePositionDeleteFiles #9449
Spark: propagate snapshot properties for RewriteDataFiles and RewritePositionDeleteFiles #9449
Conversation
…PositionDeleteFiles
cc @RussellSpitzer @szehon-ho or @aokolnychyi, would you mind to take a look at this since you guys touched most parts of the rewrite data files actions. |
@advancedxy: GH actions are down. Hence PR builders are failing. We need to wait till the status is green in https://www.githubstatus.com/ |
Thanks for the heads up. I was wondering it’s an occasional incident and tried rerunning the CI. Let’s wait GH actions back to normal. |
core/src/main/java/org/apache/iceberg/actions/RewriteDataFilesCommitManager.java
Outdated
Show resolved
Hide resolved
spark/v3.5/spark/src/test/java/org/apache/iceberg/spark/actions/TestRewriteDataFilesAction.java
Show resolved
Hide resolved
Gently ping @ajantha-bhat @ajantha-bhat @szehon-ho @aokolnychyi |
core/src/main/java/org/apache/iceberg/actions/RewriteDataFilesCommitManager.java
Outdated
Show resolved
Hide resolved
...ark/src/test/java/org/apache/iceberg/spark/actions/TestRewritePositionDeleteFilesAction.java
Outdated
Show resolved
Hide resolved
spark/v3.5/spark/src/test/java/org/apache/iceberg/spark/actions/TestRewriteDataFilesAction.java
Outdated
Show resolved
Hide resolved
I will take a look this week. |
Thanks, @advancedxy! Thanks for reviewing, @manuzhang @ajantha-bhat! |
When working with
RewriteDataFiles
, I noticed that the snapshot properties cannot be set viasnapshotProperty(String, String)
. This PR will fix that issue by propagating snapshot properties intoRewriteDataFilesCommitManager
orRewritePositionDeletesCommitManager
and all the way down toRewriteFiles
.