Questions Tags Users Badges

flink消费kafka数据，streamload的方式写入doris，如果出现脏数据错误

Asked Jun 4 Modified Jan 1, 0001

Viewed 25

2.1 ingestion

我希望让程序直接挂掉，但是现在不挂，而是在flink日志里显示doris返回的错误信息，这个有啥解决方案吗？

edited Jan 1, 0001

hwanginsitein3

1 Answers

Flink 侧捕获异常并退出
max_filter_ratio 改成0 ，MaxRetries改成0 ，失败不重试，
配置flink 作业的Restart 次数

edited Jan 1, 1970

阿渊@SelectDB (没回帖直接加我主页微信)10020

Related Questions

doris2.0.7集群迁移到新搭建的doris2.1.11集群

多台BE节点异常宕机

workload groups 设置是否合理

flink更新Doris数据

be streamload任务超时被取消但scanner线程出现coredump

doris 2.x 同步到哪个版本的doris 最稳定