[jira] [Updated] (FLINK-28054) Introduce Source API utilities to control records emitted per checkpoint

2023-07-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-28054: -- Parent: (was: FLINK-28045) Issue Type: Improvement (was: Sub-task) > Intr

[jira] [Updated] (FLINK-28054) Introduce Source API utilities to control records emitted per checkpoint

2022-06-14 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-28054: -- Description: For some connectors, it is required to verify the content of a checkpoint

[jira] [Updated] (FLINK-28054) Introduce Source API utilities to control records emitted per checkpoint

2022-06-14 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-28054: -- Description: Some connectors require verifying the content of a checkpoint after proce