读文件每一行,sink输出的顺序和原文件不一致原因是什么?
原因是:我们在keyBy操作会进行rebalance操作并且是并行计算,所以顺序就乱了。
有什么办法呢?
将全局并行度设置为1
val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment
env.setParallelism(1)
读文件每一行,sink输出的顺序和原文件不一致原因是什么?
原因是:我们在keyBy操作会进行rebalance操作并且是并行计算,所以顺序就乱了。
有什么办法呢?
将全局并行度设置为1
val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment
env.setParallelism(1)
本文标题:引入问题:
本文链接:https://www.haomeiwen.com/subject/iwrxectx.html
网友评论