You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/02/18 12:53:44 UTC
[jira] [Closed] (FLINK-5840) Aggregation functions problem
[ 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)