【解决方案】flink-doris-connector 读取doris 并发不生效问题

Viewed 66

flink 读取doris的时候,设置了flink并发,读取速度没有变化,是什么原因导致的呢

1 Answers

问题原因:
flink在读取的时候,是按照tablet切分task,目前doris.request.tablet.size 默认值是Integer. MAX_VALUE,所有即使设置了并发,但是读取的时候还是一下读取所有tablet
解决方法
设置doris.request.tablet.size = 1 即可 ,spark-doris-connector同理