2017-06-21 105 views
0

我正在使用flink从文件读取数据并将其转换为数据流,然后处理数据流。但是当我从文件读取数据并将数据转换为数据流时,数据流中的内容不在与文件中的数据顺序相同的顺序。根据我的要求,文件中和数据流中的数据顺序非常重要。任何人都可以帮助我吗?由于如何用flink中的文件数据以与数据写入文件相同的顺序创建数据流?

+2

如果你试图从一个文件中读取数据,尝试设置流的并行作业为1.此任务将按顺序运行并读取数据。 – David

回答

1

我有,当我合并多个流这个问题,并能够通过使用解决了下列文件:

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