Flink操作starrocks表全部列导入和部分列导入更新

【详述】在全部列导入的代码上指定好部分列字段导入,报错如下图片,而是让再写一个sink 导入,sink的时候固定好指定更新字段可以
【背景】在 全部列的导入增加 withProperty(“sink.properties.partial_update”,“true”).
withProperty(“sink.properties.columns”,“vin,updated_time,car_series,__op”).
【业务影响】 我想通过一个sink方法去解决全部列导入和部分列导入,而不是一个全部列sink,一个部分列sink
【StarRocks版本】2.32
【集群规模】1fe(1 follower+2observer)+2be(fe与be混部)
【机器信息】16C/64G/万兆
【表模型】主键模型
【导入或者导出方式】Flink
【联系方式】为了在解决问题过程中能及时联系到您获取一些日志信息,请补充下您的联系方式,例如:社区群4-小李或者邮箱,谢谢
【附件】
报错图片:

哪位老师熟悉这块 帮忙解决一下

怎么样,解决了吗?