[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_r155489914
  
    --- Diff: 
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceTestBase.java
 ---
    @@ -62,13 +64,15 @@
        private static final Properties PROPS = createSourceProperties();
     
        @Test
    +   @SuppressWarnings("unchecked")
        public void testKafkaConsumer() {
                KafkaTableSource.Builder b = getBuilder();
                configureBuilder(b);
     
                // assert that correct
                KafkaTableSource observed = spy(b.build());
                StreamExecutionEnvironment env = 
mock(StreamExecutionEnvironment.class);
    +           
when(env.addSource(any(SourceFunction.class))).thenReturn(mock(DataStreamSource.class));
    --- End diff --
    
    Why do we need this change?


---