This is an automated email from the ASF dual-hosted git repository.
gary pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 470fd2f [FLINK-14534][table]
FunctionCatalog.getUserDefinedFunctions() should include temp functions
add 9029b25 [hotfix][runtime] Fix checkstyle violations in ExecutionVertex
add 2377de5 [hotfix][runtime] Add overloaded method
CheckpointCoordinator#restoreLatestCheckpointedState
add 5faa81a [hotfix][tests] Introduce TestMasterHook
add 9a38946 [FLINK-14389][runtime] Restore task state before restarting
tasks in DefaultScheduler
No new revisions were added by this update.
Summary of changes:
.../runtime/checkpoint/CheckpointCoordinator.java | 35 ++++-
.../checkpoint/StateAssignmentOperation.java | 14 +-
.../runtime/executiongraph/ExecutionVertex.java | 12 +-
.../flink/runtime/scheduler/DefaultScheduler.java | 9 +-
.../flink/runtime/scheduler/SchedulerBase.java | 39 +++++-
.../CheckpointCoordinatorMasterHooksTest.java | 15 ++-
.../CheckpointCoordinatorRestoringTest.java | 34 ++---
.../checkpoint/CheckpointCoordinatorTest.java | 8 +-
.../checkpoint/CheckpointStateRestoreTest.java | 18 +--
.../runtime/checkpoint/hooks/TestMasterHook.java | 91 +++++++++++++
.../runtime/scheduler/DefaultSchedulerTest.java | 142 +++++++++++++++++++++
11 files changed, 360 insertions(+), 57 deletions(-)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/hooks/TestMasterHook.java
