使用StreamLoad 无法删除数据

【详述】 Flink通过StreamLoad 、批量导入json格式的数据,无法执行删除操作

sink 中 指定 “columns”, “__op=‘op_type’” ,根据官方文档中delete 0/1 判断是否删除数据。
但是在实际执行中未删除、

麻烦大佬指导指导!!!
麻烦大佬指导指导!!!
麻烦大佬指导指导!!!

您的设置方式不正确吗,不需要在property中指定,在slots中增加slots[slots.length-1] = StarRocksSinkOP.UPSERT.ordinal(); 等号右边的表达式代表默认upsert语义,您可以选择您对应的字段。

感谢大佬解答 。 关于这个问题我重新换了一种写法 可以解决同步删除操作、

现在又遇到了另外一个问题就是,addsink的时候如何设置动态多表写入操作、

请问动态多表写入操作 解决了吗?

方便发一下如何同步删除数据???多谢

我是修改了sink的源码可以多表写入

能参考下么? 我单挑记录执行会报: Too many versions.