[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15234552#comment-15234552 ] Aljoscha Krettek commented on FLINK-3669: - Hi, I'll be looking at your code today.

[jira] [Commented] (FLINK-3579) Improve String concatenation

[ https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15234428#comment-15234428 ] ramkrishna.s.vasudevan commented on FLINK-3579: --- [~till.rohrmann], [~till.ro

[jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API

[ https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15234427#comment-15234427 ] ramkrishna.s.vasudevan commented on FLINK-3650: --- Ping for reviews [~trohrm.

[GitHub] flink pull request: [FLINK-3477] [runtime] Add hash-based combine ...

Github user aalexandrov commented on the pull request: https://github.com/apache/flink/pull/1517#issuecomment-208083609 We've summarized the use-case around the hash aggregation experiments in [a blog post on the Peel webpage](http://peel-framework.org/2016/04/07/hash-aggregations-in-

[jira] [Commented] (FLINK-3477) Add hash-based combine strategy for ReduceFunction

[ https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15234309#comment-15234309 ] ASF GitHub Bot commented on FLINK-3477: --- Github user aalexandrov commented on the pu

[jira] [Commented] (FLINK-3665) Range partitioning lacks support to define sort orders

[ https://issues.apache.org/jira/browse/FLINK-3665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15234216#comment-15234216 ] ASF GitHub Bot commented on FLINK-3665: --- Github user dawidwys commented on a diff in

[GitHub] flink pull request: [FLINK-3665] Implemented sort orders support i...

Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/1848#discussion_r59137767 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/operators/PartitionOperator.java --- @@ -98,6 +101,14 @@ public PartitionOperator(DataSet input

[jira] [Updated] (FLINK-3723) Aggregate Functions and scalar expressions shouldn't be mixed in select

[ https://issues.apache.org/jira/browse/FLINK-3723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yijie Shen updated FLINK-3723: -- Description: When we type {code}select deptno, name, max(age) from dept group by deptno;{code} in calci

[jira] [Created] (FLINK-3723) Aggregate Functions and scalar expressions shouldn't be mixed in select

Yijie Shen created FLINK-3723: - Summary: Aggregate Functions and scalar expressions shouldn't be mixed in select Key: FLINK-3723 URL: https://issues.apache.org/jira/browse/FLINK-3723 Project: Flink