a job have two sql source is kafka sink is redis or other sink Asql
Bsql now only start Asql stop Bsql sink have key 656.19.173.34 then stop Asql and savepoint hdfs now del key 656.19.173.34( if sink is kafka Don't delete) start Bsql from savepoint you will find sink have key 656.19.173.34 and 6630519 all exist Bsql fetch Asql savepoint result i think sql uids not the only one Who can help me see this problem? -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
