Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5964
---
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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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.
17 matches
Mail list logo