This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 49a05d8 [FLINK-23093] Limit default io pool size to 4 for Mini
Cluster.
add 10db8b1 [FLINK-21246] Fail fast if a failure occurs when triggering a
checkpoint on a Task
No new revisions were added by this update.
Summary of changes:
.../runtime/checkpoint/CheckpointCoordinator.java | 141 +++++++++++----------
.../flink/runtime/executiongraph/Execution.java | 20 +--
.../jobmanager/slots/TaskManagerGateway.java | 3 +-
.../runtime/jobmaster/RpcTaskManagerGateway.java | 4 +-
.../checkpoint/CheckpointCoordinatorTest.java | 79 ++++++++++++
.../CheckpointCoordinatorTestingUtils.java | 4 +-
.../utils/SimpleAckingTaskManagerGateway.java | 3 +-
7 files changed, 173 insertions(+), 81 deletions(-)
