Repository: flink Updated Branches: refs/heads/master 26ce47f52 -> e2a00183e
Fix the message in runtime exception This closes #599 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f7ec859e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f7ec859e Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f7ec859e Branch: refs/heads/master Commit: f7ec859e8a819d2e1348e4b6612c53e1d18d3d52 Parents: 26ce47f Author: hongsibao <[email protected]> Authored: Mon Apr 13 18:37:17 2015 +0800 Committer: mbalassi <[email protected]> Committed: Fri Apr 17 15:59:34 2015 +0200 ---------------------------------------------------------------------- .../flink/runtime/akka/serialization/WritableSerializer.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/f7ec859e/flink-runtime/src/main/scala/org/apache/flink/runtime/akka/serialization/WritableSerializer.scala ---------------------------------------------------------------------- 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 25f16bd..500175b 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]
