flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From fhueske <...@git.apache.org>
Subject [GitHub] flink pull request #5068: [FLINK-8122] [table] Name all built-in table sinks...
Date Thu, 07 Dec 2017 11:21:28 GMT
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?


---

Mime
View raw message