Questions Tags Users Badges

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

Asked Jun 4 Modified Jan 1, 0001

Viewed 31

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 (没回帖直接加我主页微信)10200

Related Questions

集群规划问题

2.1.11版本，新优化器，执行计划隐式类型转换丢失精度，导致数据不一致

多台BE节点异常宕机

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

workload groups 设置是否合理

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