Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5272#discussion_r168330890
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@ -457,8 +458,8 @@ public void testCassandraTableSink() throws Exception {
}
@Test
- public void testCassandraBatchFormats() throws Exception {
- OutputFormat<Tuple3<String, Integer, Integer>> sink = new
CassandraOutputFormat<>(injectTableName(INSERT_DATA_QUERY), builder);
+ public void testCassandraBatchTupleFormats() throws Exception {
--- End diff --
done
---
