Questions Tags Users Badges

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

Asked Jun 4 Modified Jan 1, 0001

Viewed 42

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

Related Questions

with as加insert into报错，解析器解析不到insert into后面的内容

doris2.1.11版本漏洞

FE的JVM每天以1%的频率增长，原因是什么：Doris2.1.6

Doris 2.1.6版本升级至4.1.3版本详细升级路径疑问。

1900w数据量执行时内存激增到8g

permission denied问题