flink1.16 读取kafka写入doris-2.015

Viewed 44
ingestion 2.0

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

1 Answers

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

zlhxxx140
Related Questions
[CANCELLED]failed to initialize storage reader. tablet=57732, res=[E-3110][INTERNAL_ERROR]different type between schema and column reader
broker load大表导数较慢
【BUG】flink-doris-connector动态新增表后发生flink容错恢复导致新增表无法被监听
1 answers
多be中Stream Load导入慢
1 answers
doris2.0.15 unique表部分更新出现副本数据不一致
1 answers
Kafka Routine load 中报错 Socket is closed by peer
1 answers