1.3.1
1.support flink cdc
2.set ttl on first sink which key not exists
3.return null for field or val when the join don't hit
1.support flink cdc
2.set ttl on first sink which key not exists
3.return null for field or val when the join don't hit