[jira] [Created] (FLINK-1001) Aggregate Min/Max return unexpected values.

[JIRA]

Bastian Köcher created FLINK-1001:
-------------------------------------

             Summary: Aggregate Min/Max return unexpected values.
                 Key: FLINK-1001
                 URL: https://issues.apache.org/jira/browse/FLINK-1001
             Project: Flink
          Issue Type: Bug
            Reporter: Bastian Köcher


I wanted to replace my simple MinReducer
        public static class MinSimilarityReducer extends 
ReduceFunction<ClusterPair> {
                @Override
                public ClusterPair reduce(ClusterPair value1, ClusterPair 
value2) throws Exception {
                        if (value1.getSimilarity().doubleValue() < 
value2.getSimilarity().doubleValue()) {
                                return value1;
                        }
                        return value2;
                }
        }

With Aggregate.Min, but Aggregate.Min delivers a value which should already be 
removed in my WorkSet.
If I use my own Reducer it works as expected, but with an Aggregate this 
doesn't work anymore :/ 



--
This message was sent by Atlassian JIRA
(v6.2#6252)