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

【已解决】flink-connector-doris消费kafka写入doris出现问题

Asked Apr 12, 2024 Modified May 6, 2024
Viewed 67
ingestion 2.0

1712900818935.png

edited May 6, 2024
zhb123319
asked Apr 12, 2024
1 Answers

默认的心跳超时时间为5s, 心跳停止后,FE马上abort coordinate BE 的事务。实际上be没有down
然而BE事务在导入过程中并不需要fe的参与,这个5s太敏感了,建议改成超过1分钟没心跳才abort coordinate BE 的事务。

参考pr:
https://github.com/apache/doris/pull/22781

edited May 6, 2024
徐振超@SelectDB7346
answered Apr 12, 2024
Related Questions
insert into select 外部catalog表 插入数据,报要求字段not null的错误,但字段都是定义允许null
2 answers
使用flink-cdc全库同步,MySQL到doris,MySQL新加了表,不重启任务,能增量同步表到doris吗?
2 answers
【已解决】在kettle中 使用 Doris Stream loader插件 无法落库数据
3 answers
type:LOAD_RUN_FAIL; msg:errCode = 2, detailMessage = type:LOAD_RUN_FAIL; msg:errCode = 2,
1 answers
2.1.10版本使用"__DORIS_DELETE_SIGN__":1 批量删除对于routine load的一流多表测试不起作用?
1 answers
spark-doris-connector 写入异常,sql却提示成功
1 answers

Terms of service Privacy policy

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