openinx opened a new issue #2313: URL: https://github.com/apache/iceberg/issues/2313
As we are refactoring the FlinkTableFactory to implement `DynamicTableSinkFactory` and `DynamicTableSourceFactory` interfaces from flink 1.12, we will need to provide a SQL integration test to verify the CDC/Upsert data correctness as following: 1. Create a streaming source table by flink DDL; 2. Run SQL to submit flink streaming job to write CDC/Upsert events from source table to iceberg sink table; 3. At some point, stop the flink streaming job, let's verify the consistence between source table and sink table. ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
