Apache Doris 中文技术论坛
Questions Tags Users Badges

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

Asked 3h ago Modified Jan 1, 0001
Viewed 8
2.1 ingestion

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

edited Jan 1, 0001
hwanginsitein3
asked 3h ago
1 Answers
  1. Flink 侧捕获异常并退出
  2. max_filter_ratio 改成0 ,MaxRetries改成0 ,失败不重试,
  3. 配置flink 作业的Restart 次数
edited Jan 1, 1970
阿渊@SelectDB (没回帖直接加我主页微信)9940
answered 1h ago
Related Questions
doris配置ranger鉴权后,单表查询可以看到脱敏效果,但是关联查询后就失效了
1 answers
flink消费kafka数据,streamload的方式写入doris,如果出现脏数据错误
1 answers
你好,我们目前进行集群的升级中,升级到2.1.11后,这几天遇到问题老年代gc一直占满,然后不断allocrion failure,最后节点与其他fe通信受限导致exit,这个问题能不能帮忙解决一下
1 answers
doris2.1.11,be节点的数据目录下很多_tmp目录,把inode打满
1 answers
每隔2小时左右,fe master中org.apache.doris.catalog.Replica对象快速上涨,导致老年代内存飙升,触发fullgc
1 answers
doris 2.1.7 be 有时候会假死,进程还在fe那边是false
2 answers

Terms of service Privacy policy

Powered by Answer - the open-source software that powers Q&A communities.
Made with love © 2026 Apache Doris 中文技术论坛.