ahmedabu98 commented on PR #34607: URL: https://github.com/apache/beam/pull/34607#issuecomment-2798013781
Thorough testing may not be possible here because we don't yet support updating/deleting Iceberg records in Beam. I did test it locally though by: - Creating + writing to an Iceberg table using Beam - Perform some updates and deletes using Flink writers - Read it back using Beam and confirming the deleted/outdated records got filtered out When we figure out Beam CDC and add support for updating/deleting Iceberg records, we can add more thorough testing. -- 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: github-unsubscr...@beam.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
