[jira] [Commented] (FLINK-24733) Data loss in pulsar source when using shared mode

2021-11-03 Thread wang shengzhi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437761#comment-17437761 ] wang shengzhi commented on FLINK-24733: --- [~syhily] I think that the wrong understand of

[jira] [Commented] (FLINK-24733) Data loss in pulsar source when using shared mode

2021-11-02 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437460#comment-17437460 ] Yufan Sheng commented on FLINK-24733: - [~shengzhi] The fix didn't touch the core of data loss. We

[jira] [Commented] (FLINK-24733) Data loss in pulsar source when using shared mode

2021-11-02 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437403#comment-17437403 ] Yufan Sheng commented on FLINK-24733: - [~shengzhi] Tks for your fix. I'm digging into the Pulsar

[jira] [Commented] (FLINK-24733) Data loss in pulsar source when using shared mode

2021-11-02 Thread wang shengzhi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437324#comment-17437324 ] wang shengzhi commented on FLINK-24733: --- [~syhily] [~MartijnVisser] I have fixed this bug, please

[jira] [Commented] (FLINK-24733) Data loss in pulsar source when using shared mode

2021-11-02 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437320#comment-17437320 ] Martijn Visser commented on FLINK-24733: [~syhily] What are your thoughts on this one? > Data