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

Viewed 20
2.1 catalog ingestion

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

forest35
1 Answers

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

张彬华7358