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 ð
---