如何按照与数据写入文件的顺序相同的顺序从 flink 中的文件数据创建数据流？

Question

我正在使用flink从文件中读取数据并将其转换为流然后处理stream.But当我从文件中读取数据并将其转换为流时，数据流中的内容因此形成的顺序与文件中的数据顺序不同。根据我的要求，文件和流中数据的顺序很重要。任何人都可以帮助我吗？谢谢

Answer 1

我在组合多个流时遇到了这个问题，并且能够使用以下方法解决它：

    DataStream<T> stream;
    stream.setParallelism(1).rebalance();