You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2015/09/21 13:30:31 UTC
[4/7] flink git commit: [FLINK-2711] [tests] Increase timeout for
TaskManager tests upon partition lookups
[FLINK-2711] [tests] Increase timeout for TaskManager tests upon partition lookups
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a338ad08
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a338ad08
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a338ad08
Branch: refs/heads/master
Commit: a338ad08ff03621ea7055b36da54af15670ce1b0
Parents: 116cec0
Author: Stephan Ewen <se...@apache.org>
Authored: Sun Sep 20 16:12:15 2015 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Mon Sep 21 11:50:16 2015 +0200
----------------------------------------------------------------------
.../apache/flink/runtime/taskmanager/TaskManagerTest.java | 10 +++++++---
1 file changed, 7 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/a338ad08/flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskManagerTest.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskManagerTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskManagerTest.java
index 6d811b0..7b0b8f7 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskManagerTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskManagerTest.java
@@ -890,7 +890,7 @@ public class TaskManagerTest {
Collections.singletonList(igdd),
Collections.<BlobKey>emptyList(), 0);
- new Within(d) {
+ new Within(new FiniteDuration(120, TimeUnit.SECONDS)) {
@Override
protected void run() {
// Submit the task
@@ -902,8 +902,12 @@ public class TaskManagerTest {
// The task should fail after repeated requests
assertEquals(msg.getExecutionState(), ExecutionState.FAILED);
- assertEquals(msg.getError(ClassLoader.getSystemClassLoader()).getClass(),
- PartitionNotFoundException.class);
+
+ Throwable error = msg.getError(getClass().getClassLoader());
+ if (error.getClass() != PartitionNotFoundException.class) {
+ error.printStackTrace();
+ fail("Wrong exception: " + error.getMessage());
+ }
}
};
}