通过flink-doris-connector 写入 报错 Lable has been used

Viewed 20

一流多表写入 doris 出现 Lable has been used image.png
请问如何处理,另外 如何配置DorisExecutionOptions写入参数才可以更高效地写入,避免反压?

1 Answers

1、Exactly-Once 场景下,Flink Job 重启时必须从最新的 Checkpoint/Savepoint 启动,否则会报如上错误。不要求 Exactly-Once 时,也可通过关闭 2PC 提交(sink.enable-2pc=false)或更换不同的 sink.label-prefix 解决。
2、可以调大并发写入,单批次数据量至少上万
具体内容可以查阅Flink Doris Connector章节