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

2017-11-01 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3748 Thanks for the update @PangZhi. Btw. it is recommended to post a short comment when you update a PR. Pushing an update does not trigger a notification. The PR looks good. Will merge

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

2017-10-26 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3748 Thanks for the update and reminder @PangZhi. I'll have a look tomorrow. Maybe we can include this in the upcoming 1.4.0 release. Thanks, Fabian ---

[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-18 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3748 ``` [ERROR] src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraRowSink.java:[20,8] (imports) UnusedImports: Unused import: org.apache.flink.configuration.Configuration.

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

2017-10-16 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3748 A few minor things left, but we're in pretty good shape now. ---

[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 haohui
Github user haohui commented on the issue: https://github.com/apache/flink/pull/3748 Given we have dropped the support for Java 7, it might make sense to just rewrite the class to use the completablefuture in java 8. ---

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

2017-10-09 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3748 When importing guava you have to explicitly add an exclusion to https://github.com/apache/flink/blob/master/tools/maven/suppressions.xml. ---

[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 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 issue #3748: [FLINK-6225] [Cassandra Connector] add CassandraTableSink

2017-05-15 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3748 Apart from the above this looks ok to me. --- 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

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

2017-05-15 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3748 You will have to rebase this PR and adjust the tests. I recently modified the cassandra tests to no longer run any actual jobs. --- If your project is set up for it, you can reply to this email and

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

2017-05-15 Thread haohui
Github user haohui commented on the issue: https://github.com/apache/flink/pull/3748 @zentol can you please take another look? Thanks. --- 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