[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Table API / SQL UIDs not the only one

a job  have two sql
source is kafka
sink is redis  or other sink



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: