再试了一下:
修改并行度也不行
                .setParallelism(9)




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

回复