Hi ravi Do you read streaming data with filesystem connector? By default, the file system is bound. If you need to read streaming data, you can look at the configuration `source.monitor.interval` in https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/filesystem/#directory-watching, and see whether your job is executed in streaming mode and trigger checkpoint regularly.
Best, Shammon On Mon, Mar 13, 2023 at 12:36 AM Shammon FY <zjur...@gmail.com> wrote: > >