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

    https://github.com/apache/flink/pull/5125#discussion_r154951890
  
    --- Diff: 
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/collector/selector/CopyingDirectedOutput.java
 ---
    @@ -36,7 +36,7 @@
        @SuppressWarnings({"unchecked", "rawtypes"})
        public CopyingDirectedOutput(
                        List<OutputSelector<OUT>> outputSelectors,
    -                   List<Tuple2<Output<StreamRecord<OUT>>, StreamEdge>> 
outputs) {
    +                   List<? extends Tuple2<? extends 
Output<StreamRecord<OUT>>, StreamEdge>> outputs) {
    --- End diff --
    
    nice 😉 


---

Reply via email to