DataLinkDC / dinky

Dinky is a real-time data development platform based on Apache Flink, enabling agile data development, deployment and operation.
http://www.dinky.org.cn
Apache License 2.0
2.95k stars 1.08k forks source link

Flink Doris Sink Missing configuration item #3628

Closed ljs033 closed 1 week ago

ljs033 commented 1 week ago

Search before asking

What happened

微信图片_20240705094141

What you expected to happen

在 'sink.connector' = 'datastream-doris-schema-evolution'下使用 'sink.doris.batch.size' = '1000', 'sink.sink.batch.interval' = '60000',这两个配置项,观察日志没有产生什么变化,无法实现按指定的批次数量或者批次时间间隔进行数据写入doris中。期望这两个参数能有效的使用

How to reproduce

代码中的这个datastream-doris-schema-evolution没有传递'sink.doris.batch.size', 'sink.sink.batch.interval' 这两个配置项

Anything else

No response

Version

dev

Are you willing to submit PR?

Code of Conduct

ljs033 commented 1 week ago

'sink.sink.batch.size'还有一个这个参数也没传递