[GitHub] [flink] zhijiangW commented on a change in pull request #13209: [FLINK-18832][datastream] Add compatible check for blocking partition with buffer timeout

zhijiangW commented on a change in pull request #13209: URL: https://github.com/apache/flink/pull/13209#discussion_r484169545 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java ## @@ -609,6 +609,32 @@ publi

[GitHub] [flink] zhijiangW commented on a change in pull request #13209: [FLINK-18832][datastream] Add compatible check for blocking partition with buffer timeout

zhijiangW commented on a change in pull request #13209: URL: https://github.com/apache/flink/pull/13209#discussion_r484164187 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java ## @@ -136,6 +172,14 @@ public void setPartitione

[GitHub] [flink] zhijiangW commented on a change in pull request #13209: [FLINK-18832][datastream] Add compatible check for blocking partition with buffer timeout

zhijiangW commented on a change in pull request #13209: URL: https://github.com/apache/flink/pull/13209#discussion_r484164586 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java ## @@ -99,6 +99,10 @@ p

[GitHub] [flink] zhijiangW commented on a change in pull request #13209: [FLINK-18832][datastream] Add compatible check for blocking partition with buffer timeout

zhijiangW commented on a change in pull request #13209: URL: https://github.com/apache/flink/pull/13209#discussion_r484164187 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java ## @@ -136,6 +172,14 @@ public void setPartitione

[GitHub] [flink] zhijiangW commented on a change in pull request #13209: [FLINK-18832][datastream] Add compatible check for blocking partition with buffer timeout

zhijiangW commented on a change in pull request #13209: URL: https://github.com/apache/flink/pull/13209#discussion_r484164187 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java ## @@ -136,6 +172,14 @@ public void setPartitione

[GitHub] [flink] zhijiangW commented on a change in pull request #13209: [FLINK-18832][datastream] Add compatible check for blocking partition with buffer timeout

zhijiangW commented on a change in pull request #13209: URL: https://github.com/apache/flink/pull/13209#discussion_r484164187 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java ## @@ -136,6 +172,14 @@ public void setPartitione

[GitHub] [flink] zhijiangW commented on a change in pull request #13209: [FLINK-18832][datastream] Add compatible check for blocking partition with buffer timeout

zhijiangW commented on a change in pull request #13209: URL: https://github.com/apache/flink/pull/13209#discussion_r484156753 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java ## @@ -76,32 +76,68 @@ private final Sh

[GitHub] [flink] zhijiangW commented on a change in pull request #13209: [FLINK-18832][datastream] Add compatible check for blocking partition with buffer timeout

zhijiangW commented on a change in pull request #13209: URL: https://github.com/apache/flink/pull/13209#discussion_r479139680 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java ## @@ -609,6 +609,33 @@ publi

[GitHub] [flink] zhijiangW commented on a change in pull request #13209: [FLINK-18832][datastream] Add compatible check for blocking partition with buffer timeout

zhijiangW commented on a change in pull request #13209: URL: https://github.com/apache/flink/pull/13209#discussion_r479080606 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java ## @@ -285,11 +285,7 @@ public StreamGr

[GitHub] [flink] zhijiangW commented on a change in pull request #13209: [FLINK-18832][datastream] Add compatible check for blocking partition with buffer timeout

zhijiangW commented on a change in pull request #13209: URL: https://github.com/apache/flink/pull/13209#discussion_r479082702 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java ## @@ -591,6 +593,13 @@ private v

[GitHub] [flink] zhijiangW commented on a change in pull request #13209: [FLINK-18832][datastream] Add compatible check for blocking partition with buffer timeout

zhijiangW commented on a change in pull request #13209: URL: https://github.com/apache/flink/pull/13209#discussion_r479080606 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java ## @@ -285,11 +285,7 @@ public StreamGr