Heatao opened a new pull request, #15061:
URL: https://github.com/apache/iceberg/pull/15061
This fixes an inconsistency where DELETE operations did not respect custom
snapshot properties set via session config, while INSERT and UPDATE operations
did.
### Changes
- Added `SparkWriteConf.extraSnapshotMetadata()` call in
`SparkTable.deleteFromRowFilter()`
- Added test coverage for DELETE, TRUNCATE, and multi-operation scenarios
- Applied fix to both Spark 4.0 and 4.1
### Testing
```java
spark.conf().set("spark.sql.iceberg.snapshot-property.custom-key",
"custom-value");
sql("DELETE FROM table WHERE id = 1");
Closes #15060
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
