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/08/30 20:45:49 UTC
[3/4] flink git commit: [FLINK-2543] [core] Fix user object
deserialization for file-based state handles.
http://git-wip-us.apache.org/repos/asf/flink/blob/bf8c8e54/flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/taskmanager/TaskManagerFailsITCase.scala
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/taskmanager/TaskManagerFailsITCase.scala b/flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/taskmanager/TaskManagerFailsITCase.scala
index d108798..1952760 100644
--- a/flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/taskmanager/TaskManagerFailsITCase.scala
+++ b/flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/taskmanager/TaskManagerFailsITCase.scala
@@ -33,6 +33,7 @@ import org.apache.flink.runtime.messages.TaskManagerMessages.{RegisteredAtJobMan
import org.apache.flink.runtime.testingUtils.TestingJobManagerMessages._
import org.apache.flink.runtime.testingUtils.TestingMessages.DisableDisconnect
import org.apache.flink.runtime.testingUtils.{ScalaTestingUtils, TestingUtils}
+import org.apache.flink.runtime.util.SerializedThrowable
import org.apache.flink.test.util.ForkableFlinkMiniCluster
import org.junit.runner.RunWith
@@ -126,8 +127,8 @@ class TaskManagerFailsITCase(_system: ActorSystem)
}
val failure = expectMsgType[Failure]
-
- failure.cause match {
+ val exception = SerializedThrowable.get(failure.cause, this.getClass.getClassLoader)
+ exception match {
case e: JobExecutionException =>
jobGraph.getJobID should equal(e.getJobID)
@@ -169,8 +170,8 @@ class TaskManagerFailsITCase(_system: ActorSystem)
taskManagers(0) ! Kill
val failure = expectMsgType[Failure]
-
- failure.cause match {
+ val exception = SerializedThrowable.get(failure.cause, this.getClass.getClassLoader)
+ exception match {
case e: JobExecutionException =>
jobGraph.getJobID should equal(e.getJobID)
@@ -208,8 +209,8 @@ class TaskManagerFailsITCase(_system: ActorSystem)
tm ! PoisonPill
val failure = expectMsgType[Failure]
-
- failure.cause match {
+ val exception = SerializedThrowable.get(failure.cause, this.getClass.getClassLoader)
+ exception match {
case e: JobExecutionException =>
jobGraph.getJobID should equal(e.getJobID)