[GitHub] flink pull request #5068: [FLINK-8122] [table] Name all built-in table sinks...

[fhueske]

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

    https://github.com/apache/flink/pull/5068#discussion_r155492981
  
    --- Diff: 
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraAppendTableSink.java
 ---
    @@ -80,9 +81,15 @@ public void emitDataStream(DataStream<Row> dataStream) {
                        CassandraSink.addSink(dataStream)
                                .setClusterBuilder(this.builder)
                                .setQuery(this.cql)
    -                           .build();
    +                           .build()
    +                           .name(explainSink());
    --- End diff --
    
    Call `TableConnectorUtil.genRuntimeName(this.getClass().getSimpleName(), 
fieldNames)` directly?


---