You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2016/03/08 16:14:44 UTC
flink git commit: [hotfix] Improve exception message in
TaskManagerTest#testRemotePartitionNotFound
Repository: flink
Updated Branches:
refs/heads/master fe117afd3 -> 09ce3dcc3
[hotfix] Improve exception message in TaskManagerTest#testRemotePartitionNotFound
This closes #1658
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/09ce3dcc
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/09ce3dcc
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/09ce3dcc
Branch: refs/heads/master
Commit: 09ce3dcc3144484b088b6b29d7cca5061ea10937
Parents: fe117af
Author: zentol <ch...@apache.org>
Authored: Tue Mar 8 16:13:07 2016 +0100
Committer: zentol <ch...@apache.org>
Committed: Tue Mar 8 16:13:51 2016 +0100
----------------------------------------------------------------------
.../org/apache/flink/runtime/taskmanager/TaskManagerTest.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/09ce3dcc/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 b9f4cbf..b80cb0e 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
@@ -917,8 +917,9 @@ public class TaskManagerTest extends TestLogger {
// The task should fail after repeated requests
assertEquals(ExecutionState.FAILED, msg.getExecutionState());
- assertEquals(PartitionNotFoundException.class,
- msg.getError(ClassLoader.getSystemClassLoader()).getClass());
+ Throwable t = msg.getError(ClassLoader.getSystemClassLoader());
+ assertEquals("Thrown exception was not a PartitionNotFoundException: " + t.getMessage(),
+ PartitionNotFoundException.class, t.getClass());
}
};
}