flinksql写Doris标记删除时'sink.enable-delete' = 'false'的含义

Question

照着这个方式实现了删除的效果，但是不太理解sink.enable-delete参数的含义，当我把它设置为true进行尝试时实现不了删除，false可以，这个参数的含义是啥呢？为啥为true时就不行了

徐振超@SelectDB · Answer

sink.enable-delete 表示是否启用删除。此选项需要 Doris 表开启批量删除功能 (Doris0.15+ 版本默认开启)，只支持 Unique 模型。

你上面的例子是：DorisSink 默认会根据 RowKind 来区分事件的类型，通常这种在 cdc 情况下可以直接获取到事件类型，对隐藏列DORIS_DELETE_SIGN进行赋值达到删除的目的，而 Kafka 则需要根据业务逻辑判断，显示的传入隐藏列的值。