[
https://issues.apache.org/jira/browse/FLINK-3911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15283144#comment-15283144
]
Fabian Hueske commented on FLINK-3911:
--------------------------------------
Is it possible that the Flink version of the submitting client and the cluster
do not match?
Strategies are passed as ENUMs and the index does not match if different
versions for client and cluster are used and a new strategy was added between
versions.
> 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
> Labels: newbie
>
> 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
(v6.3.4#6332)
