[GitHub] [flink] xintongsong commented on a diff in pull request #21419: [FLINK-30233] Hybrid full result partition should also work with speculative execution

xintongsong commented on code in PR #21419: URL: https://github.com/apache/flink/pull/21419#discussion_r1053028752 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/AdaptiveBatchScheduler.java: ## @@ -78,6 +79,8 @@ public class

[GitHub] [flink] xintongsong commented on a diff in pull request #21419: [FLINK-30233] Hybrid full result partition should also work with speculative execution

xintongsong commented on code in PR #21419: URL: https://github.com/apache/flink/pull/21419#discussion_r1043991638 ## flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java: ## @@ -605,6 +605,17 @@ public enum SchedulerType {

[GitHub] [flink] xintongsong commented on a diff in pull request #21419: [FLINK-30233] Hybrid full result partition should also work with speculative execution

xintongsong commented on code in PR #21419: URL: https://github.com/apache/flink/pull/21419#discussion_r1040349304 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsMemoryDataManager.java: ## @@ -181,18 +188,33 @@ public HsDataView