Repository: flink Updated Branches: refs/heads/master 47ec09e10 -> 383ae265c
[FLINK-1365] Fix ValueTypeInfo Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/59970361 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/59970361 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/59970361 Branch: refs/heads/master Commit: 59970361c11b8177edbf56786e896ce4da82c6ba Parents: 47ec09e Author: Aljoscha Krettek <[email protected]> Authored: Thu Dec 18 16:14:21 2014 +0100 Committer: Aljoscha Krettek <[email protected]> Committed: Wed Jan 7 14:47:31 2015 +0100 ---------------------------------------------------------------------- .../java/org/apache/flink/api/java/typeutils/ValueTypeInfo.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/59970361/flink-java/src/main/java/org/apache/flink/api/java/typeutils/ValueTypeInfo.java ---------------------------------------------------------------------- diff --git a/flink-java/src/main/java/org/apache/flink/api/java/typeutils/ValueTypeInfo.java b/flink-java/src/main/java/org/apache/flink/api/java/typeutils/ValueTypeInfo.java index b3c25e4..2e40ff9 100644 --- a/flink-java/src/main/java/org/apache/flink/api/java/typeutils/ValueTypeInfo.java +++ b/flink-java/src/main/java/org/apache/flink/api/java/typeutils/ValueTypeInfo.java @@ -96,10 +96,10 @@ public class ValueTypeInfo<T extends Value> extends TypeInformation<T> implement } if (CopyableValue.class.isAssignableFrom(type)) { - return (TypeComparator<T>) new ValueComparator(sortOrderAscending, type); + return (TypeComparator<T>) new CopyableValueComparator(sortOrderAscending, type); } else { - return (TypeComparator<T>) new CopyableValueComparator(sortOrderAscending, type); + return (TypeComparator<T>) new ValueComparator(sortOrderAscending, type); } }
