This is an automated email from the ASF dual-hosted git repository.
zhuzh pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 94ce6f9 [FLINK-21975] Remove hamcrest dependency from
SchedulerBenchmarkBase
add 75f6cc9 [hotfix] Make IterableUtils.flatMap return Iterable rather
than Iterator
add 9c95cc1 [FLINK-21331] Optimize calculating tasks to restart in
RestartPipelinedRegionFailoverStrategy
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/flink/util/IterableUtils.java | 47 +++++------
.../RestartPipelinedRegionFailoverStrategy.java | 90 ++++++++++++++++------
.../scheduler/adapter/DefaultExecutionVertex.java | 4 +-
.../scheduler/adapter/DefaultResultPartition.java | 4 +-
.../strategy/TestingSchedulingExecutionVertex.java | 4 +-
.../strategy/TestingSchedulingResultPartition.java | 4 +-
6 files changed, 100 insertions(+), 53 deletions(-)
