[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251434#comment-16251434 ] ASF GitHub Bot commented on FLINK-4500: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249046#comment-16249046 ] ASF GitHub Bot commented on FLINK-4500: --- GitHub user mcfongtw opened a pull request:

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16248266#comment-16248266 ] ASF GitHub Bot commented on FLINK-4500: --- Github user mcfongtw commented on the issue:

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16247315#comment-16247315 ] ASF GitHub Bot commented on FLINK-4500: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16247304#comment-16247304 ] ASF GitHub Bot commented on FLINK-4500: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16244995#comment-16244995 ] ASF GitHub Bot commented on FLINK-4500: --- Github user mcfongtw commented on the issue:

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16243753#comment-16243753 ] ASF GitHub Bot commented on FLINK-4500: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241624#comment-16241624 ] ASF GitHub Bot commented on FLINK-4500: --- Github user mcfongtw commented on the issue:

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182579#comment-16182579 ] ASF GitHub Bot commented on FLINK-4500: --- Github user mcfongtw commented on the issue:

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173073#comment-16173073 ] ASF GitHub Bot commented on FLINK-4500: --- Github user mcfongtw commented on a diff in the pull

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16171644#comment-16171644 ] ASF GitHub Bot commented on FLINK-4500: --- Github user mcfongtw commented on a diff in the pull

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16171647#comment-16171647 ] ASF GitHub Bot commented on FLINK-4500: --- Github user mcfongtw commented on a diff in the pull

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16171519#comment-16171519 ] ASF GitHub Bot commented on FLINK-4500: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16171509#comment-16171509 ] ASF GitHub Bot commented on FLINK-4500: --- Github user mcfongtw commented on a diff in the pull

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16171344#comment-16171344 ] ASF GitHub Bot commented on FLINK-4500: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16171323#comment-16171323 ] ASF GitHub Bot commented on FLINK-4500: --- Github user mcfongtw commented on a diff in the pull

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16171231#comment-16171231 ] ASF GitHub Bot commented on FLINK-4500: --- Github user mcfongtw commented on a diff in the pull

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170344#comment-16170344 ] ASF GitHub Bot commented on FLINK-4500: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170346#comment-16170346 ] ASF GitHub Bot commented on FLINK-4500: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170345#comment-16170345 ] ASF GitHub Bot commented on FLINK-4500: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170336#comment-16170336 ] ASF GitHub Bot commented on FLINK-4500: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170339#comment-16170339 ] ASF GitHub Bot commented on FLINK-4500: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170347#comment-16170347 ] ASF GitHub Bot commented on FLINK-4500: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170343#comment-16170343 ] ASF GitHub Bot commented on FLINK-4500: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170341#comment-16170341 ] ASF GitHub Bot commented on FLINK-4500: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170348#comment-16170348 ] ASF GitHub Bot commented on FLINK-4500: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170342#comment-16170342 ] ASF GitHub Bot commented on FLINK-4500: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170337#comment-16170337 ] ASF GitHub Bot commented on FLINK-4500: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170338#comment-16170338 ] ASF GitHub Bot commented on FLINK-4500: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170340#comment-16170340 ] ASF GitHub Bot commented on FLINK-4500: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170335#comment-16170335 ] ASF GitHub Bot commented on FLINK-4500: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16160180#comment-16160180 ] Michael Fong commented on FLINK-4500: - There is a PR looking for reviewer. Thanks! Regards, Michael

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16142979#comment-16142979 ] ASF GitHub Bot commented on FLINK-4500: --- GitHub user mcfongtw opened a pull request:

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16139448#comment-16139448 ] Michael Fong commented on FLINK-4500: - I plan to design the first part of the requirement on existing

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16125541#comment-16125541 ] Chesnay Schepler commented on FLINK-4500: - [~mcfongtw] feel free to work on this issue, I have

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16124486#comment-16124486 ] Michael Fong commented on FLINK-4500: - Hi, I would like to help implement Checkpointed in

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008756#comment-16008756 ] Chesnay Schepler commented on FLINK-4500: - The second part of this issue (tracking in-flight