[
https://issues.apache.org/jira/browse/FLINK-27816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-27816:
-----------------------------------
Component/s: Connectors / FileSystem
> file source reader has Some requirements
> ----------------------------------------
>
> Key: FLINK-27816
> URL: https://issues.apache.org/jira/browse/FLINK-27816
> Project: Flink
> Issue Type: Improvement
> Components: Connectors / FileSystem
> Affects Versions: 1.15.0
> Reporter: jinshuangxian
> Priority: Major
>
> I use the flink sql file-system connector to consume data, write it to object
> storage, and use the file-system consumption to process the data in the
> object storage. The whole process works fine. I have 2 new requirements:
> 1. can I specify a timestamp to consume files within a specified time range
> 2. It is hoped that the data written to the object storage can be ordered in
> the partition (for example, partitioned according to the device id), and the
> file source reader can consume the files in an orderly manner similar to
> kafka when consuming files.
> Can some enhancements be made to the file source reader?
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
