如何用flink中的文件數據以與數據寫入文件相同的順序創建數據流？

Question

我正在使用flink從文件讀取數據並將其轉換爲數據流，然後處理數據流。但是當我從文件讀取數據並將數據轉換爲數據流時，數據流中的內容不在與文件中的數據順序相同的順序。根據我的要求，文件中和數據流中的數據順序非常重要。任何人都可以幫助我嗎？由於

Answer 1

我有，當我合併多個流這個問題，並能夠通過使用解決了下列文件：

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