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

["Bastian Köcher (JIRA)" <ji...@apache.org>]

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)