owen6314 opened a new pull request, #14594: URL: https://github.com/apache/iceberg/pull/14594
Resolves #14160 Currently, the FlinkSink only supports specifying static snapshot properties at build time via the builder API. There is no built-in way to set or customize snapshot properties dynamically for each commit or checkpoint. Extend the FlinkSink to allow users to provide a function that generates snapshot properties dynamically. This would enable users to inject custom metadata, such as row counts, min/max timestamps, or task-specific annotations into Iceberg snapshots at runtime. Similar to how [snapshot-property.custom-key](https://github.com/apache/iceberg/pull/14545) works in Spark. -- 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]
