Questions
Tags
Users
Badges
flink消费kafka数据,streamload的方式写入doris,如果出现脏数据错误
Asked 3h ago
Modified Jan 1, 0001
Viewed 8
2.1
ingestion
我希望让程序直接挂掉,但是现在不挂,而是在flink日志里显示doris返回的错误信息,这个有啥解决方案吗?
0
0
edited Jan 1, 0001
hwanginsitein
3
asked 3h ago
1 Answers
Flink 侧捕获异常并退出
max_filter_ratio 改成0 ,MaxRetries改成0 ,失败不重试,
配置flink 作业的Restart 次数
0
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