fixup! [FLINK-21386][datastream] Assert that AbstractUdfStreamOperato…

…r redirects OutputTypeConfigurable to function
apache · Apr 7, 2021 · c5adc24 · c5adc24
1 parent c12fdaf
commit c5adc24
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ing-java/src/test/java/org/apache/flink/streaming/api/graph/StreamGraphGeneratorTest.java b/...ing-java/src/test/java/org/apache/flink/streaming/api/graph/StreamGraphGeneratorTest.java
@@ -219,10 +219,10 @@ public void testOutputTypeConfigurationWithUdfStreamOperator() throws Exception
 
         DataStream<Integer> source = env.fromElements(1, 10);
 
-        NoOpUdfOperator<Integer> udfOperator = new NoOpUdfOperator(function);
+        NoOpUdfOperator<Integer> udfOperator = new NoOpUdfOperator<>(function);
 
         source.transform("no-op udf operator", BasicTypeInfo.INT_TYPE_INFO, udfOperator)
-                .addSink(new DiscardingSink());
+                .addSink(new DiscardingSink<>());
 
         env.getStreamGraph();