CJDrew commented on issue #9948: URL: https://github.com/apache/iceberg/issues/9948#issuecomment-2372401940
@pvary Hi Peter, I am also interested in this feature. I see in iceberg-spark we have the ability to use the procedure "create_changelog_view" and I wonder how difficult it would be to implement something similar as a Flink source. Do you know if there's an implementation for streaming v2 tables yet? Are there any other major roadblocks you're aware of? I also see there is an ongoing proposal for row lineage here: [PR](https://github.com/apache/iceberg/pull/11130) I'm wondering if it makes sense to pursue Flink CDC right now given these potential changes. Thanks! Carter -- 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: issues-unsubscr...@iceberg.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache.org For additional commands, e-mail: issues-h...@iceberg.apache.org