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

    https://github.com/apache/flink/pull/5970#discussion_r187601380
  
    --- Diff: 
flink-java/src/test/java/org/apache/flink/api/java/sca/UdfAnalyzerTest.java ---
    @@ -268,8 +274,8 @@ public void 
testForwardIntoNestedTupleWithVarAndModification() {
     
        @Test
        public void testForwardIntoTupleWithAssignment() {
    -           
compareAnalyzerResultWithAnnotationsSingleInput(MapFunction.class, Map14.class, 
"Tuple2<String,Integer>",
    -                           "Tuple2<String,String>");
    +           
compareAnalyzerResultWithAnnotationsSingleInput(MapFunction.class, Map14.class,
    +                   TypeInformation.of(new TypeHint<Tuple2<String, 
Integer>>(){}), TypeInformation.of(new TypeHint<Tuple2<String, String>>(){}));
    --- End diff --
    
    accept this suggestion


---

Reply via email to