You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2017/12/14 13:14:33 UTC
flink git commit: [FLINK-8262] [tests] Harden
IndividualRestartsConcurrencyTest.testLocalFailureFailsPendingCheckpoints
Repository: flink
Updated Branches:
refs/heads/master 840cbfbf0 -> e80dd8ea3
[FLINK-8262] [tests] Harden IndividualRestartsConcurrencyTest.testLocalFailureFailsPendingCheckpoints
The problem was a concurrent restart attempt which failed due to not enough
available slots. This failure would lead to the job failure and the discarding
of all pending checkpoints.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e80dd8ea
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e80dd8ea
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e80dd8ea
Branch: refs/heads/master
Commit: e80dd8ea3fef0398048a40c3ffd5136bef204b80
Parents: 840cbfb
Author: Till Rohrmann <tr...@apache.org>
Authored: Thu Dec 14 12:57:04 2017 +0100
Committer: Till Rohrmann <tr...@apache.org>
Committed: Thu Dec 14 14:10:35 2017 +0100
----------------------------------------------------------------------
.../runtime/executiongraph/IndividualRestartsConcurrencyTest.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/e80dd8ea/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/IndividualRestartsConcurrencyTest.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/IndividualRestartsConcurrencyTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/IndividualRestartsConcurrencyTest.java
index 85a6c2c..32ccad1 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/IndividualRestartsConcurrencyTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/IndividualRestartsConcurrencyTest.java
@@ -305,8 +305,7 @@ public class IndividualRestartsConcurrencyTest extends TestLogger {
when(taskManagerGateway.cancelTask(any(ExecutionAttemptID.class), any(Time.class))).thenReturn(CompletableFuture.completedFuture(Acknowledge.get()));
final SimpleSlotProvider slotProvider = new SimpleSlotProvider(jid, parallelism, taskManagerGateway);
- final Executor executor = TestingUtils.defaultExecutor();
-
+ final ManuallyTriggeredDirectExecutor executor = new ManuallyTriggeredDirectExecutor();
final CheckpointCoordinatorConfiguration checkpointCoordinatorConfiguration = new CheckpointCoordinatorConfiguration(
10L,