[GitHub] [iceberg] openinx opened a new issue #2313: Flink: Provide the fully covered SQL integration test cases to verify the data correctness.

[GitBox <gi...@apache.org>]

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:
users@infra.apache.org



---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@iceberg.apache.org
For additional commands, e-mail: issues-help@iceberg.apache.org