Github user fhueske commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5272#discussion_r168177338
  
    --- 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 --
    
    rename to `testCassandraBatchTupleFormat` (-s)


---

Reply via email to