flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From WeiWen Fan <yushuf...@gmail.com>
Subject Table API / SQL UIDs not the only one
Date Tue, 23 Oct 2018 02:06:56 GMT
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/

Mime
View raw message