flink版本:1.12.2
es connector版本:es7对应的版本

<http://apache-flink.147419.n8.nabble.com/file/t1408/a.png> 
在ES的官方BulkProcessor中有个concurrentRequest参数,来提高执行的并行度
但是flink es
connector中无法设置该参数,查看源码,在ElasticsearchSinkBase类buildBulkProcessor方法中,将concurrentRequest设置为0,使得无法异步执行。

<http://apache-flink.147419.n8.nabble.com/file/t1408/b5.png> 
请问有办法修改这个配置吗?



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复