xianyouQ
xianyouQ
I merged this PR and did some testing. i used flink cdc to consume binlog and wrote to iceberg table, then run some flink sql query(streaming) and compared with mysql...
> For this issue, config `write.upsert.enabled` is not suitable for CDC. So if your scene is CDC you can config it false that result `upsert` false. Thanks , I also...
Another issue, After run rewrite data file action and expire snapshot action(retain one Last snapshot), and then started a new flink streaming job, it did not read the old data....
same problem, anything update?
测试不能用啊，是我的问题吗？我看代码使用了encoding/json，tinygo不支持吧