[
https://issues.apache.org/jira/browse/FLINK-1001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi resolved FLINK-1001.
--------------------------------
Resolution: Later
> Aggregate Min/Max return unexpected values.
> -------------------------------------------
>
> Key: FLINK-1001
> URL: https://issues.apache.org/jira/browse/FLINK-1001
> Project: Flink
> Issue Type: Bug
> Components: Local Runtime
> Reporter: Bastian Köcher
> Attachments: src.zip
>
>
> 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)
