[GitHub] flink issue #4883: [FLINK-4809] Operators should tolerate checkpoint failure...

2017-11-07 Thread PangZhi
Github user PangZhi commented on the issue: https://github.com/apache/flink/pull/4883 @StefanRRichter do we have any update on this PR? ---

[GitHub] flink issue #3748: [FLINK-6225] [Cassandra Connector] add CassandraTableSink

2017-10-26 Thread PangZhi
Github user PangZhi commented on the issue: https://github.com/apache/flink/pull/3748 @zentol Hey zentol, when do you think we will be able to merge in. ---

[GitHub] flink issue #3748: [FLINK-6225] [Cassandra Connector] add CassandraTableSink

2017-10-19 Thread PangZhi
Github user PangZhi commented on the issue: https://github.com/apache/flink/pull/3748 @zentol thx, fixed. ---

[GitHub] flink issue #3748: [FLINK-6225] [Cassandra Connector] add CassandraTableSink

2017-10-13 Thread PangZhi
Github user PangZhi commented on the issue: https://github.com/apache/flink/pull/3748 @zentol @fhueske Can you take another look. ---

[GitHub] flink issue #3748: [FLINK-6225] [Cassandra Connector] add CassandraTableSink

2017-10-10 Thread PangZhi
Github user PangZhi commented on the issue: https://github.com/apache/flink/pull/3748 @zentol Do you mind taking another look. ---

[GitHub] flink issue #3748: [FLINK-6225] [Cassandra Connector] add CassandraTableSink

2017-10-09 Thread PangZhi
Github user PangZhi commented on the issue: https://github.com/apache/flink/pull/3748 @fhueske Hi zentol hasn't replied can you help to take a look. thx ---

[GitHub] flink issue #3748: [FLINK-6225] [Cassandra Connector] add CassandraTableSink

2017-10-06 Thread PangZhi
Github user PangZhi commented on the issue: https://github.com/apache/flink/pull/3748 @zentol and do you know why import com.google.common.util.concurrent.ListenableFuture becomes illegal import? The checkstyle error is blocking CI. However this class is brought in from base class. ---

[GitHub] flink pull request #3748: [FLINK-6225] [Cassandra Connector] add CassandraTa...

2017-10-05 Thread PangZhi
Github user PangZhi commented on a diff in the pull request: https://github.com/apache/flink/pull/3748#discussion_r143098834 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java

[GitHub] flink issue #3748: [FLINK-6225] [Cassandra Connector] add CassandraTableSink

2017-05-16 Thread PangZhi
Github user PangZhi commented on the issue: https://github.com/apache/flink/pull/3748 @zentol can you take another look? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled

[GitHub] flink pull request #3748: [FLINK-6225] [Cassandra Connector] add CassandraTa...

2017-04-26 Thread PangZhi
Github user PangZhi commented on a diff in the pull request: https://github.com/apache/flink/pull/3748#discussion_r113505564 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java

[GitHub] flink pull request #3748: [FLINK-6225] [Cassandra Connector] add CassandraTa...

2017-04-20 Thread PangZhi
GitHub user PangZhi opened a pull request: https://github.com/apache/flink/pull/3748 [FLINK-6225] [Cassandra Connector] add CassandraTableSink This PR is to address https://issues.apache.org/jira/browse/FLINK-6225 - add Row type support for CassandraSink - add