[
https://issues.apache.org/jira/browse/FLINK-5840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-5840.
--------------------------------
Resolution: Invalid
The reported behavior of {{max()}} is correct.
The desired behavior can be implemented using {{maxBy()}}.
> Aggregation functions problem
> -----------------------------
>
> Key: FLINK-5840
> URL: https://issues.apache.org/jira/browse/FLINK-5840
> Project: Flink
> Issue Type: Bug
> Components: Core
> Affects Versions: 1.2.0
> Environment: Windows 10, Eclipse Neon(2)
> Reporter: Kursat Kurt
>
> Flink 1.2 aggregation functions does not work.
> Please run the code below. Also you can check SUM and MIN functions in the
> same way.
> object Test {
> def main(args: Array[String]) {
> val env = ExecutionEnvironment.getExecutionEnvironment
> val ds: DataSet[(Long, String, Double)] = env.fromElements(
> (0, "Auto", 5.8317538999854194E-5),
> (0, "Computer", 4.8828125E-5),
> (0, "Sports", 1.7495261699956258E-4),
> (1, "Auto", 1.7495261699956258E-4),
> (1, "Computer", 4.8828125E-5),
> (1, "Sports", 5.8317538999854194E-5))
> ds.groupBy(0).max(2).print();
> }
> }
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
