[jira] [Commented] (FLINK-28049) Introduce FLIP-208 functionality to stop Source based on consumed records

2022-10-11 Thread Sergey Troshkov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17616187#comment-17616187 ] Sergey Troshkov commented on FLINK-28049: - Thank you! > Introduce FLIP-208 func

[jira] [Commented] (FLINK-28049) Introduce FLIP-208 functionality to stop Source based on consumed records

2022-10-11 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615599#comment-17615599 ] Martijn Visser commented on FLINK-28049: You can find the FLIP at https://cwiki

[jira] [Commented] (FLINK-28049) Introduce FLIP-208 functionality to stop Source based on consumed records

2022-10-11 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615598#comment-17615598 ] Martijn Visser commented on FLINK-28049: [~stroshkov] Like mentioned in the PR,

[jira] [Commented] (FLINK-28049) Introduce FLIP-208 functionality to stop Source based on consumed records

2022-10-11 Thread Sergey Troshkov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615580#comment-17615580 ] Sergey Troshkov commented on FLINK-28049: - Hi! I created PR for this issue. [ht

[jira] [Commented] (FLINK-28049) Introduce FLIP-208 functionality to stop Source based on consumed records

2022-10-05 Thread Sergey Troshkov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17613297#comment-17613297 ] Sergey Troshkov commented on FLINK-28049: - Hi [~afedulov]! I am interested in th