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

flink1.16 读取kafka写入doris-2.015

Asked Oct 29, 2024 Modified Jan 1, 0001
Viewed 45
ingestion 2.0

image.png
这个个配置感觉不生效,全是根据checkpoint的时间来写入数据的。checkpoint的我也不能设置太短,这样导致数据延迟很大,有方法可以解决吗,谢谢大家帮忙看看呢

edited Jan 1, 0001
he1234563
asked Oct 29, 2024
1 Answers

有没有开启batch模式提交,没有就是checkpoint,这些参数只在batch模式下生效

edited Oct 29, 2024
zlhxxx142
answered Oct 29, 2024
Related Questions
int类型写入数据超过范围不报错
logstash-output-doris-1.2.0.zip 离线安装包不存在
2 answers
sqoop 从hdfs导入doris
1 answers
Doris存算分离架构压测指标上不去
1 answers
Flink CdcTools 使用Oracle XStream方式 初始化时无问题,在增量同步时无法识别Oracle Date类型数据,会将目标字段值设为NULL
1 answers
Flink CdcTools 使用Logminer方式 oracle 单库模式下 如果某张表 列名长度超30字符 将无法捕获
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 中文技术论坛.