From deae58893a00ca79c6ed225c47b9150e239f0022 Mon Sep 17 00:00:00 2001 From: hongsibao Date: Mon, 13 Apr 2015 18:37:17 +0800 Subject: [PATCH] Fix the message in runtime exception --- .../flink/runtime/akka/serialization/WritableSerializer.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-runtime/src/main/scala/org/apache/flink/runtime/akka/serialization/WritableSerializer.scala b/flink-runtime/src/main/scala/org/apache/flink/runtime/akka/serialization/WritableSerializer.scala index 25f16bd27538b..500175b57e087 100644 --- a/flink-runtime/src/main/scala/org/apache/flink/runtime/akka/serialization/WritableSerializer.scala +++ b/flink-runtime/src/main/scala/org/apache/flink/runtime/akka/serialization/WritableSerializer.scala @@ -32,7 +32,7 @@ class WritableSerializer extends JSerializer { val instance = InstantiationUtil.instantiate(manifest) if(!instance.isInstanceOf[Writable]){ - throw new RuntimeException(s"Class $manifest is not of type IOReadableWritable.") + throw new RuntimeException(s"Class $manifest is not of type Writable.") } val writable = instance.asInstanceOf[Writable]