This is an automated email from the ASF dual-hosted git repository.
sewen pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from a871333 [FLINK-22144][runtime][runtime-web] Adds more documentation
and moves option
new 772eb8e [refactor][runtime] Update FutureUtils to support delayed
completing of a CompletableFuture
new 0726c9e [refactor][runtime] Extend AkkaRpcServiceUtils to support
instantiating custom AkkaRpcServices.
new ea4b391 [FLINK-21996][refactor] Make IteratorSourceReader work with
multiple split requests.
new d6253f4 [FLINK-21996][refactor] Make NumberSequenceSource extensible
to allow specifying the number of desired sequence splits.
new de509fc [FLINK-21996][tests] Add ITCase to test for delayed and
failed operator event sending.
new 8ddd456 [FLINK-21996][refactor] Unify exception handling for Operator
Coordinator Events sent to not-running tasks
new ad54508 [FLINK-21996][refactor] Pull in-line serialization call into
separate statement to improve Exception handling accuracy.
new 4595ec7 [FLINK-18071][coordination] (part 1) All event sending and
checkpoint actions for OperatorCoordinator happen in Scheduler Thread
The 8 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../connector/source/lib/NumberSequenceSource.java | 45 ++-
.../source/lib/util/IteratorSourceReader.java | 80 ++--
.../source/lib/NumberSequenceSourceTest.java | 6 +-
.../flink/runtime/concurrent/FutureUtils.java | 15 +
.../coordination/OperatorCoordinator.java | 3 +-
.../coordination/OperatorCoordinatorHolder.java | 70 ++--
.../operators/coordination/OperatorEventValve.java | 211 +++++-----
.../RecreateOnResetOperatorCoordinator.java | 2 +-
.../runtime/rpc/akka/AkkaRpcServiceUtils.java | 9 +-
.../coordinator/SourceCoordinatorContext.java | 35 +-
.../TaskExecutorGatewayDecoratorBase.java | 231 +++++++++++
.../CoordinatorEventsExactlyOnceITCase.java | 14 +-
.../MockOperatorCoordinatorContext.java | 3 +-
.../OperatorCoordinatorSchedulerTest.java | 15 +
.../coordination/OperatorEventValveTest.java | 34 +-
.../OperatorEventSendingCheckpointITCase.java | 450 +++++++++++++++++++++
16 files changed, 983 insertions(+), 240 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorGatewayDecoratorBase.java
create mode 100644
flink-tests/src/test/java/org/apache/flink/runtime/operators/coordination/OperatorEventSendingCheckpointITCase.java
