Zu
Zu
> If you want to use paimon's upsert feature, your source should be mysql-cdc. In addition, the checkpoint.interval parameter is not supported for batch write in paimon sink, because the...
I tried to explain why I use JDBC source connector and batch mode, but perhaps I wasn't clear. Well, there's a bug that only occurs in seatunnel's batch mode (CDC...
let's focus only the insert behavior of sink and paimon. a PK table using deduplicate merge engine, like: `create table test(id int, tchar string, primary key(id) not enforced);` , and...
> > let's focus only the insert behavior of sink and paimon. a PK table using deduplicate merge engine, like: `create table test(id int, tchar string, primary key(id) not enforced);`...
Yes ,same primary key `id`, and I would use `paimon.table.primary-keys` to specify in sink
same result as used JDBC source. first, insert five records into an empty table: ``` hocon env { parallelism = 1 job.mode = "BATCH" } source { FakeSource { schema...
> @MirrerZu Thanks for your feedback, please use this pr to make a new jar of paimon connector. It works well for me, Thanks!
2.7-prerelease-3 仍然有这个问题 --- 2.7-prerelease-3 still has this problem