[FLINK-1328] Added previously failing semantic annotations to examples and fixed them by enabling partitioning on AtomicTypes.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/805ea694 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/805ea694 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/805ea694 Branch: refs/heads/master Commit: 805ea69431d378de93bec8d067721f21370cde37 Parents: 4c2c426 Author: Fabian Hueske <[email protected]> Authored: Wed Jan 14 16:48:07 2015 +0100 Committer: Fabian Hueske <[email protected]> Committed: Wed Jan 28 01:39:01 2015 +0100 ---------------------------------------------------------------------- .../java/org/apache/flink/compiler/postpass/JavaApiPostPass.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/805ea694/flink-compiler/src/main/java/org/apache/flink/compiler/postpass/JavaApiPostPass.java ---------------------------------------------------------------------- diff --git a/flink-compiler/src/main/java/org/apache/flink/compiler/postpass/JavaApiPostPass.java b/flink-compiler/src/main/java/org/apache/flink/compiler/postpass/JavaApiPostPass.java index 2273461..6295170 100644 --- a/flink-compiler/src/main/java/org/apache/flink/compiler/postpass/JavaApiPostPass.java +++ b/flink-compiler/src/main/java/org/apache/flink/compiler/postpass/JavaApiPostPass.java @@ -294,7 +294,7 @@ public class JavaApiPostPass implements OptimizerPostPass { } else if (typeInfo instanceof AtomicType) { // handle grouping of atomic types - throw new UnsupportedOperationException("Grouping on atomic types is currently not implemented. " + typeInfo); + comparator = ((AtomicType) typeInfo).createComparator(sortOrder[0]); } else { throw new RuntimeException("Unrecognized type: " + typeInfo);
