[GitHub] [flink] zhuzhurk commented on a diff in pull request #19653: [FLINK-27523] Runtime supports producing and consuming cached intermediate results

zhuzhurk commented on code in PR #19653: URL: https://github.com/apache/flink/pull/19653#discussion_r891870085 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java: ## @@ -296,12 +300,36 @@ private void handleTaskFailure( final long

[GitHub] [flink] zhuzhurk commented on a diff in pull request #19653: [FLINK-27523] Runtime supports producing and consuming cached intermediate results

zhuzhurk commented on code in PR #19653: URL: https://github.com/apache/flink/pull/19653#discussion_r889953568 ## flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobIntermediateDatasetReuseTest.java: ## @@ -0,0 +1,284 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] zhuzhurk commented on a diff in pull request #19653: [FLINK-27523] Runtime supports producing and consuming cached intermediate results

zhuzhurk commented on code in PR #19653: URL: https://github.com/apache/flink/pull/19653#discussion_r886323585 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/JobMasterPartitionTrackerImpl.java: ## @@ -120,6 +125,26 @@ public Collection

[GitHub] [flink] zhuzhurk commented on a diff in pull request #19653: [FLINK-27523] Runtime supports producing and consuming cached intermediate results

zhuzhurk commented on code in PR #19653: URL: https://github.com/apache/flink/pull/19653#discussion_r886299714 ## flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobIntermediateDatasetReuseTest.java: ## @@ -0,0 +1,239 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] zhuzhurk commented on a diff in pull request #19653: [FLINK-27523] Runtime supports producing and consuming cached intermediate results

zhuzhurk commented on code in PR #19653: URL: https://github.com/apache/flink/pull/19653#discussion_r872369788 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapter/DefaultSchedulingPipelinedRegion.java: ## @@ -42,6 +43,8 @@ public class