This is an automated email from the ASF dual-hosted git repository.
azagrebin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 60b6401 [FLINK-19836] Add SimpleVersionedSerializerTypeSerializerProxy
add 0c7186a [hotfix][coordination] Refactor Builder for
TestingSchedulingExecutionVertex in tests
add 787d0c6 [hotfix][coordination] Add execution state to
RestartPipelinedRegionFailoverStrategyTest
add 9b059cf [hotfix][coordination] Deduplicate verification logic in
RestartPipelinedRegionFailoverStrategyTest
add 1e42bb4 [FLINK-19712][Coordination] Do not restart CREATED executions
in RestartPipelinedRegionFailoverStrategy
No new revisions were added by this update.
Summary of changes:
.../RestartPipelinedRegionFailoverStrategy.java | 8 +-
...RestartPipelinedRegionFailoverStrategyTest.java | 343 ++++++++-------------
.../PipelinedRegionExecutionViewTest.java | 6 +-
.../strategy/EagerSchedulingStrategyTest.java | 20 +-
.../InputDependencyConstraintCheckerTest.java | 90 +++---
.../strategy/TestingSchedulingExecutionVertex.java | 77 ++++-
.../strategy/TestingSchedulingTopology.java | 22 +-
.../recovery/BatchFineGrainedRecoveryITCase.java | 5 +-
8 files changed, 272 insertions(+), 299 deletions(-)