[GitHub] [flink] damjad commented on a change in pull request #12136: [FLINK-17578][flink-streaming] Union of 2 SideOutputs behaviour incorrect

2020-05-14 Thread GitBox
damjad commented on a change in pull request #12136: URL: https://github.com/apache/flink/pull/12136#discussion_r425085400 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java ## @@ -137,7 +137,12 @@ public void setPartitioner(S

[GitHub] [flink] damjad commented on a change in pull request #12136: [FLINK-17578][flink-streaming] Union of 2 SideOutputs behaviour incorrect

2020-05-14 Thread GitBox
damjad commented on a change in pull request #12136: URL: https://github.com/apache/flink/pull/12136#discussion_r425085499 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java ## @@ -150,8 +155,9 @@ public boolean equals(Object