In the 3.1 separated storage and computation version, the use of the "insert into" statement in Flink SQL will lose the data with delete rowkind.

StarRocks / starrocks-connector-for-apache-flink

Apache License 2.0

189 stars 152 forks source link

In the 3.1 separated storage and computation version, the use of the "insert into" statement in Flink SQL will lose the data with delete rowkind. #364

Open andystenhe opened 3 months ago

andystenhe commented 3 months ago

I am using the upsert Kafka connector to read Kafka messages and then write them to the primary key table in StarRocks, but I noticed that the data with row kind as delete is not being written to StarRocks.

My StarRocks version is 3.1.2 with the separated storage and computation architecture, the Flink connector version is 2.8.1, and the Flink version is 1.14.5.