[FLINK-2194] [type extractor] Excludes Writable type from WritableTypeInformation to be treated as an interface
This closes #814. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f5f0709c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f5f0709c Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f5f0709c Branch: refs/heads/release-0.9 Commit: f5f0709c9ba090cd1321dec761a27db556082630 Parents: 40e2df5 Author: Till Rohrmann <trohrm...@apache.org> Authored: Tue Jun 9 16:11:05 2015 +0200 Committer: Fabian Hueske <fhue...@apache.org> Committed: Fri Jun 12 14:28:52 2015 +0200 ---------------------------------------------------------------------- .../java/org/apache/flink/api/java/typeutils/TypeExtractor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/f5f0709c/flink-java/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java ---------------------------------------------------------------------- diff --git a/flink-java/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java b/flink-java/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java index 71d0cee..41644f9 100644 --- a/flink-java/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java +++ b/flink-java/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java @@ -1152,7 +1152,7 @@ public class TypeExtractor { } // check for writable types - if(Writable.class.isAssignableFrom(clazz)) { + if(Writable.class.isAssignableFrom(clazz) && !Writable.class.equals(clazz)) { return (TypeInformation<OUT>) WritableTypeInfo.getWritableTypeInfo((Class<? extends Writable>) clazz); }
