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 4050cf3 [FLINK-17808] Rename checkpoint meta file to "_metadata"
until it has completed writing
add 8fc657b8 [FLINK-25669][runtime] Support register operator coordinators
for newly initialized ExecutionJobVertex
No new revisions were added by this update.
Summary of changes:
.../DefaultOperatorCoordinatorHandler.java | 62 +++++++++-----
.../scheduler/OperatorCoordinatorHandler.java | 12 +++
.../flink/runtime/scheduler/SchedulerBase.java | 3 +
.../coordination/TestingOperatorCoordinator.java | 2 +-
.../DefaultOperatorCoordinatorHandlerTest.java | 99 ++++++++++++++++++++++
.../TestingOperatorCoordinatorHandler.java | 9 ++
6 files changed, 167 insertions(+), 20 deletions(-)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultOperatorCoordinatorHandlerTest.java
