[GitHub] [flink] reswqa commented on a diff in pull request #19927: [FLINK-27903][runtime] Introduce and support HYBRID resultPartitionType

reswqa commented on code in PR #19927: URL: https://github.com/apache/flink/pull/19927#discussion_r896405257 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java: ## @@ -1201,6 +1243,33 @@ private void verifyFractions(

[GitHub] [flink] reswqa commented on a diff in pull request #19927: [FLINK-27903][runtime] Introduce and support HYBRID resultPartitionType

reswqa commented on code in PR #19927: URL: https://github.com/apache/flink/pull/19927#discussion_r896405257 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java: ## @@ -1201,6 +1243,33 @@ private void verifyFractions(

[GitHub] [flink] reswqa commented on a diff in pull request #19927: [FLINK-27903][runtime] Introduce and support HYBRID resultPartitionType

reswqa commented on code in PR #19927: URL: https://github.com/apache/flink/pull/19927#discussion_r894305350 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java: ## @@ -984,6 +989,10 @@ private void connect(Integer headOfCha