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/
