[ https://issues.apache.org/jira/browse/FLINK-3911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Leonard Xu updated FLINK-3911: ------------------------------ Labels: starter (was: newbie) > Sort operation before a group reduce doesn't seem to be implemented on 1.0.2 > ---------------------------------------------------------------------------- > > Key: FLINK-3911 > URL: https://issues.apache.org/jira/browse/FLINK-3911 > Project: Flink > Issue Type: Bug > Affects Versions: 1.0.2 > Environment: Linux Ubuntu, standalone cluster > Reporter: Patrice Freydiere > Priority: Major > Labels: starter > > i have this piece of code: > // group by id and sort on field order > DataSet<Tuple2<Long, byte[]>> waysGeometry = > joinedWaysWithPoints.groupBy(0).sortGroup(1, Order.ASCENDING) > .reduceGroup(new > GroupReduceFunction<Tuple4<Long, Integer, Double, Double>, Tuple2<Long, > byte[]>>() { > @Override > public void > reduce(Iterable<Tuple4<Long, Integer, Double, Double>> values, > > Collector<Tuple2<Long, byte[]>> out) throws Exception { > long id = -1; > and this exception when executing ; > ava.lang.Exception: The data preparation for task 'GroupReduce (GroupReduce > at constructOSMStreams(ProcessOSM.java:112))' , caused an error: Unrecognized > driver strategy for GroupReduce driver: SORTED_GROUP_COMBINE > at org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:456) > at > org.apache.flink.runtime.operators.BatchTask.invoke(BatchTask.java:345) > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559) > at java.lang.Thread.run(Thread.java:745) > Caused by: java.lang.Exception: Unrecognized driver strategy for GroupReduce > driver: SORTED_GROUP_COMBINE > at > org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:90) > at org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:450) > ... 3 more -- This message was sent by Atlassian Jira (v8.20.10#820010)