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

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16160180#comment-16160180 ] Michael Fong edited comment on FLINK-4500 at 9/13/17 7:54 AM: --

[jira] [Assigned] (FLINK-4498) Better Cassandra sink documentation

[ https://issues.apache.org/jira/browse/FLINK-4498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Fong reassigned FLINK-4498: --- Assignee: Michael Fong > Better Cassandra sink documentation > --

[jira] [Commented] (FLINK-4498) Better Cassandra sink documentation

[ https://issues.apache.org/jira/browse/FLINK-4498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168827#comment-16168827 ] Michael Fong commented on FLINK-4498: - I would like to help updating the documents for

[jira] [Comment Edited] (FLINK-4498) Better Cassandra sink documentation

[ https://issues.apache.org/jira/browse/FLINK-4498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168827#comment-16168827 ] Michael Fong edited comment on FLINK-4498 at 9/16/17 2:39 PM: --

[jira] [Created] (FLINK-7632) Better documentation on C* sink usage for Pojo and Tuples data types

Michael Fong created FLINK-7632: --- Summary: Better documentation on C* sink usage for Pojo and Tuples data types Key: FLINK-7632 URL: https://issues.apache.org/jira/browse/FLINK-7632 Project: Flink

[jira] [Created] (FLINK-7633) Better documentation on C* sink on consistency guarantee

Michael Fong created FLINK-7633: --- Summary: Better documentation on C* sink on consistency guarantee Key: FLINK-7633 URL: https://issues.apache.org/jira/browse/FLINK-7633 Project: Flink Issue Ty

[jira] [Updated] (FLINK-7632) Better documentation and examples on C* sink usage for Pojo and Tuples data types

[ https://issues.apache.org/jira/browse/FLINK-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Fong updated FLINK-7632: Summary: Better documentation and examples on C* sink usage for Pojo and Tuples data types (was: Be

[jira] [Updated] (FLINK-7632) Better documentation and examples on C* sink usage for Pojo and Tuples data types

[ https://issues.apache.org/jira/browse/FLINK-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Fong updated FLINK-7632: Description: Cassandra sink supports Pojo and Java Tuple data types. We should improve documentation

[jira] [Updated] (FLINK-7633) Better documentation on C* sink on consistency guarantee

[ https://issues.apache.org/jira/browse/FLINK-7633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Fong updated FLINK-7633: Description: We should improve the usage of write-ahead log of Cassandra sink and conditions or limi

[jira] [Assigned] (FLINK-7839) Creating Quickstart project for SNAPSHOT version fails

[ https://issues.apache.org/jira/browse/FLINK-7839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Fong reassigned FLINK-7839: --- Assignee: Michael Fong > Creating Quickstart project for SNAPSHOT version fails > ---

[jira] [Commented] (FLINK-7839) Creating Quickstart project for SNAPSHOT version fails

[ https://issues.apache.org/jira/browse/FLINK-7839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16204390#comment-16204390 ] Michael Fong commented on FLINK-7839: - I can help update the document since I also enc

[jira] [Comment Edited] (FLINK-7839) Creating Quickstart project for SNAPSHOT version fails

[ https://issues.apache.org/jira/browse/FLINK-7839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16204390#comment-16204390 ] Michael Fong edited comment on FLINK-7839 at 10/14/17 12:34 AM:

[jira] [Comment Edited] (FLINK-7839) Creating Quickstart project for SNAPSHOT version fails

[ https://issues.apache.org/jira/browse/FLINK-7839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16204390#comment-16204390 ] Michael Fong edited comment on FLINK-7839 at 10/14/17 12:41 AM:

[jira] [Commented] (FLINK-7839) Creating Quickstart project for SNAPSHOT version fails

[ https://issues.apache.org/jira/browse/FLINK-7839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16204394#comment-16204394 ] Michael Fong commented on FLINK-7839: - >From above comment, I propose we could put a n

[jira] [Comment Edited] (FLINK-7839) Creating Quickstart project for SNAPSHOT version fails

[ https://issues.apache.org/jira/browse/FLINK-7839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16204394#comment-16204394 ] Michael Fong edited comment on FLINK-7839 at 10/14/17 12:46 AM:

[jira] [Comment Edited] (FLINK-7839) Creating Quickstart project for SNAPSHOT version fails

[ https://issues.apache.org/jira/browse/FLINK-7839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16204394#comment-16204394 ] Michael Fong edited comment on FLINK-7839 at 10/14/17 7:56 AM: -

[jira] [Commented] (FLINK-7839) Creating Quickstart project for SNAPSHOT version fails

[ https://issues.apache.org/jira/browse/FLINK-7839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16207188#comment-16207188 ] Michael Fong commented on FLINK-7839: - I looked at the doc code, and there is an if-st

[jira] [Commented] (FLINK-6805) Flink Cassandra connector dependency on Netty disagrees with Flink

[ https://issues.apache.org/jira/browse/FLINK-6805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16119971#comment-16119971 ] Michael Fong commented on FLINK-6805: - All other flink libraries depends on 4.0.27, ex

[jira] [Commented] (FLINK-6805) Flink Cassandra connector dependency on Netty disagrees with Flink

[ https://issues.apache.org/jira/browse/FLINK-6805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120885#comment-16120885 ] Michael Fong commented on FLINK-6805: - Thanks for your comment, [~Zentol], I see the

[jira] [Comment Edited] (FLINK-6805) Flink Cassandra connector dependency on Netty disagrees with Flink

[ https://issues.apache.org/jira/browse/FLINK-6805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120885#comment-16120885 ] Michael Fong edited comment on FLINK-6805 at 8/11/17 2:50 AM: --

[jira] [Comment Edited] (FLINK-6805) Flink Cassandra connector dependency on Netty disagrees with Flink

[ https://issues.apache.org/jira/browse/FLINK-6805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120885#comment-16120885 ] Michael Fong edited comment on FLINK-6805 at 8/11/17 10:02 AM: -

[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&focusedCommentId=16124486#comment-16124486 ] Michael Fong commented on FLINK-4500: - Hi, I would like to help implement Checkpointe

[jira] [Assigned] (FLINK-6805) Flink Cassandra connector dependency on Netty disagrees with Flink

[ https://issues.apache.org/jira/browse/FLINK-6805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Fong reassigned FLINK-6805: --- Assignee: Michael Fong > Flink Cassandra connector dependency on Netty disagrees with Flink >

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

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Fong reassigned FLINK-4500: --- Assignee: Michael Fong > Cassandra sink can lose messages >

[jira] [Commented] (FLINK-6805) Flink Cassandra connector dependency on Netty disagrees with Flink

[ https://issues.apache.org/jira/browse/FLINK-6805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16127200#comment-16127200 ] Michael Fong commented on FLINK-6805: - Hi, [~Zentol], Thanks for your reply. I have c

[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&focusedCommentId=16139448#comment-16139448 ] Michael Fong commented on FLINK-4500: - I plan to design the first part of the requirem

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

[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16139448#comment-16139448 ] Michael Fong edited comment on FLINK-4500 at 8/24/17 1:36 AM: --

[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&focusedCommentId=16160180#comment-16160180 ] Michael Fong commented on FLINK-4500: - There is a PR looking for reviewer. Thanks! Re