[GitHub] flink pull request #4605: [FLINK-4500] [C* Connector] CassandraSinkBase impl...

2017-11-10 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4605 ---

[GitHub] flink pull request #4605: [FLINK-4500] [C* Connector] CassandraSinkBase impl...

2017-09-20 Thread mcfongtw
Github user mcfongtw commented on a diff in the pull request: https://github.com/apache/flink/pull/4605#discussion_r139950435 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseTest.java --- @@ -0,0

[GitHub] flink pull request #4605: [FLINK-4500] [C* Connector] CassandraSinkBase impl...

2017-09-19 Thread mcfongtw
Github user mcfongtw commented on a diff in the pull request: https://github.com/apache/flink/pull/4605#discussion_r139685528 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseTest.java --- @@ -0,0

[GitHub] flink pull request #4605: [FLINK-4500] [C* Connector] CassandraSinkBase impl...

2017-09-19 Thread mcfongtw
Github user mcfongtw commented on a diff in the pull request: https://github.com/apache/flink/pull/4605#discussion_r139685362 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseTest.java --- @@ -0,0

[GitHub] flink pull request #4605: [FLINK-4500] [C* Connector] CassandraSinkBase impl...

2017-09-19 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4605#discussion_r139660015 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBase.java --- @@ -37,29

[GitHub] flink pull request #4605: [FLINK-4500] [C* Connector] CassandraSinkBase impl...

2017-09-19 Thread mcfongtw
Github user mcfongtw commented on a diff in the pull request: https://github.com/apache/flink/pull/4605#discussion_r139658146 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBase.java --- @@ -37,29

[GitHub] flink pull request #4605: [FLINK-4500] [C* Connector] CassandraSinkBase impl...

2017-09-19 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4605#discussion_r139632915 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBase.java --- @@ -37,29

[GitHub] flink pull request #4605: [FLINK-4500] [C* Connector] CassandraSinkBase impl...

2017-09-19 Thread mcfongtw
Github user mcfongtw commented on a diff in the pull request: https://github.com/apache/flink/pull/4605#discussion_r139630504 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBase.java --- @@ -37,29

[GitHub] flink pull request #4605: [FLINK-4500] [C* Connector] CassandraSinkBase impl...

2017-09-19 Thread mcfongtw
Github user mcfongtw commented on a diff in the pull request: https://github.com/apache/flink/pull/4605#discussion_r139615174 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseTest.java --- @@ -0,0

[GitHub] flink pull request #4605: [FLINK-4500] [C* Connector] CassandraSinkBase impl...

2017-09-18 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4605#discussion_r139485608 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseTest.java --- @@ -0,0

[GitHub] flink pull request #4605: [FLINK-4500] [C* Connector] CassandraSinkBase impl...

2017-09-18 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4605#discussion_r139484760 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBase.java --- @@ -37,29

[GitHub] flink pull request #4605: [FLINK-4500] [C* Connector] CassandraSinkBase impl...

2017-09-18 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4605#discussion_r139485057 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseTest.java --- @@ -0,0

[GitHub] flink pull request #4605: [FLINK-4500] [C* Connector] CassandraSinkBase impl...

2017-09-18 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4605#discussion_r139483818 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseTest.java --- @@ -0,0

[GitHub] flink pull request #4605: [FLINK-4500] [C* Connector] CassandraSinkBase impl...

2017-09-18 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4605#discussion_r139482771 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseTest.java --- @@ -0,0

[GitHub] flink pull request #4605: [FLINK-4500] [C* Connector] CassandraSinkBase impl...

2017-09-18 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4605#discussion_r139484838 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseTest.java --- @@ -0,0

[GitHub] flink pull request #4605: [FLINK-4500] [C* Connector] CassandraSinkBase impl...

2017-09-18 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4605#discussion_r139482708 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseTest.java --- @@ -0,0

[GitHub] flink pull request #4605: [FLINK-4500] [C* Connector] CassandraSinkBase impl...

2017-09-18 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4605#discussion_r139482639 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseTest.java --- @@ -0,0

[GitHub] flink pull request #4605: [FLINK-4500] [C* Connector] CassandraSinkBase impl...

2017-09-18 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4605#discussion_r139482886 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseTest.java --- @@ -0,0

[GitHub] flink pull request #4605: [FLINK-4500] [C* Connector] CassandraSinkBase impl...

2017-09-18 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4605#discussion_r139482849 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseTest.java --- @@ -0,0

[GitHub] flink pull request #4605: [FLINK-4500] [C* Connector] CassandraSinkBase impl...

2017-09-18 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4605#discussion_r139483098 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseTest.java --- @@ -0,0

[GitHub] flink pull request #4605: [FLINK-4500] [C* Connector] CassandraSinkBase impl...

2017-09-18 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4605#discussion_r139482897 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseTest.java --- @@ -0,0

[GitHub] flink pull request #4605: [FLINK-4500] [C* Connector] CassandraSinkBase impl...

2017-09-18 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4605#discussion_r139482615 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseTest.java --- @@ -0,0

[GitHub] flink pull request #4605: [FLINK-4500] [C* Connector] CassandraSinkBase impl...

2017-09-18 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4605#discussion_r139484328 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseTest.java --- @@ -0,0

[GitHub] flink pull request #4605: [FLINK-4500] [C* Connector] CassandraSinkBase impl...

2017-08-26 Thread mcfongtw
GitHub user mcfongtw opened a pull request: https://github.com/apache/flink/pull/4605 [FLINK-4500] [C* Connector] CassandraSinkBase implements CheckpointedFunction ## What is the purpose of the change Have CassandraSinkBase to implement CheckpointedFunction so that all