Flink CDC 只支持 StarRocks 中的主键模型中的 UPDATE 和 INSERT 操作,而不支持 DELETE 操作。要支持 DELETE 操作,请确保您的 StarRocks 数据表定义了 PRIMARY KEY 并设置为 AUTO_INCREMENT 类型,并且您的 Flink CDC 配置文件正确设置了 scan.startup.mode 参数。
以下是一些简单的步骤:
- 定义 PRIMARY KEY 并将其设置为 AUTO_INCREMENT 类型:
CREATE TABLE your_table ( id INT NOT NULL AUTO_INCREMENT, name VARCHAR(10), PRIMARY KEY (id) );
- 更新 Flink CDC 配置文件:
sql-client.sh catalog starrocks write into your_table --scan.startup.mode earliest-offset --update-mode retract -d db_name -t your_table --write-mode upsert -H localhost -u user_name -p password
在这个命令行中,添加 --scan.startup.mode earliest-offset
和 --update-mode retract
选项来支持 StarRocks 主键模型中的 DELETE 操作。