You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Yaroslav Tkachenko (Jira)" <ji...@apache.org> on 2023/03/01 23:58:00 UTC
[jira] [Created] (FLINK-31285) FileSource should support reading files in order
Yaroslav Tkachenko created FLINK-31285:
------------------------------------------
Summary: FileSource should support reading files in order
Key: FLINK-31285
URL: https://issues.apache.org/jira/browse/FLINK-31285
Project: Flink
Issue Type: New Feature
Components: Connectors / FileSystem
Affects Versions: 1.18.0
Reporter: Yaroslav Tkachenko
Currently, Flink's *FileSource* uses *LocalityAwareSplitAssigner* as a default *FileSplitAssigner* and it doesn't guarantee any order. In many scenarios involving processing historical data, reading files in order can be a requirement, especially when using event-time processing.
I believe a new FileSplitAssigner should be implemented that supports ordering. FileSourceBuilder should be extended to allow choosing a different FileSplitAssigner.
It's also clear that the files may not be read in _perfect_ order with parallelism > 1. However, in some cases, using parallelism of 1 might be fine.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)