[GitHub] flink pull request #5964: [FLINK-8655] [Cassandra Connector] add keyspace in...

2018-05-29 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5964 ---

[GitHub] flink pull request #5964: [FLINK-8655] [Cassandra Connector] add keyspace in...

2018-05-17 Thread ctamisier
Github user ctamisier commented on a diff in the pull request: https://github.com/apache/flink/pull/5964#discussion_r189056714 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java --- @@

[GitHub] flink pull request #5964: [FLINK-8655] [Cassandra Connector] add keyspace in...

2018-05-16 Thread ctamisier
Github user ctamisier commented on a diff in the pull request: https://github.com/apache/flink/pull/5964#discussion_r188727153 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java --- @@ -381,6

[GitHub] flink pull request #5964: [FLINK-8655] [Cassandra Connector] add keyspace in...

2018-05-16 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5964#discussion_r188722661 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java --- @@ -381,6 +393,9

[GitHub] flink pull request #5964: [FLINK-8655] [Cassandra Connector] add keyspace in...

2018-05-16 Thread ctamisier
Github user ctamisier commented on a diff in the pull request: https://github.com/apache/flink/pull/5964#discussion_r188717750 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java --- @@ -381,6

[GitHub] flink pull request #5964: [FLINK-8655] [Cassandra Connector] add keyspace in...

2018-05-16 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5964#discussion_r188545721 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java --- @@ -258,6 +259,17

[GitHub] flink pull request #5964: [FLINK-8655] [Cassandra Connector] add keyspace in...

2018-05-16 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5964#discussion_r188545817 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java --- @@ -410,6 +425,9

[GitHub] flink pull request #5964: [FLINK-8655] [Cassandra Connector] add keyspace in...

2018-05-16 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5964#discussion_r188546432 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java --- @@

[GitHub] flink pull request #5964: [FLINK-8655] [Cassandra Connector] add keyspace in...

2018-05-16 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5964#discussion_r188545761 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java --- @@ -381,6 +393,9

[GitHub] flink pull request #5964: [FLINK-8655] [Cassandra Connector] add keyspace in...

2018-05-16 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5964#discussion_r188546038 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java --- @@ -470,6 +488,9

[GitHub] flink pull request #5964: [FLINK-8655] [Cassandra Connector] add keyspace in...

2018-05-16 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5964#discussion_r188545921 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java --- @@ -381,6 +393,9

[GitHub] flink pull request #5964: [FLINK-8655] [Cassandra Connector] add keyspace in...

2018-05-08 Thread ctamisier
Github user ctamisier commented on a diff in the pull request: https://github.com/apache/flink/pull/5964#discussion_r186714037 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBase.java --- @@ -85,7

[GitHub] flink pull request #5964: [FLINK-8655] [Cassandra Connector] add keyspace in...

2018-05-08 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5964#discussion_r186700920 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBase.java --- @@ -85,7 +85,7

[GitHub] flink pull request #5964: [FLINK-8655] [Cassandra Connector] add keyspace in...

2018-05-08 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5964#discussion_r186673807 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraPojoSink.java --- @@ -50,18

[GitHub] flink pull request #5964: [FLINK-8655] [Cassandra Connector] add keyspace in...

2018-05-08 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5964#discussion_r186674717 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java --- @@

[GitHub] flink pull request #5964: [FLINK-8655] [Cassandra Connector] add keyspace in...

2018-05-08 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5964#discussion_r186673889 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java --- @@

[GitHub] flink pull request #5964: [FLINK-8655] [Cassandra Connector] add keyspace in...

2018-05-07 Thread ctamisier
GitHub user ctamisier opened a pull request: https://github.com/apache/flink/pull/5964 [FLINK-8655] [Cassandra Connector] add keyspace in cassandra sink builder ## What is the purpose of the change This PR is an alternative to https://github.com/apache/flink/pull/5538.