[
https://issues.apache.org/jira/browse/FLINK-2549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14905674#comment-14905674
]
ASF GitHub Bot commented on FLINK-2549:
---------------------------------------
Github user ChengXiangLi commented on the pull request:
https://github.com/apache/flink/pull/1161#issuecomment-142782327
Thanks, @StephanEwen , I'm totally agree with you about the memory
allocation. Actually i tried to understand the memory allocation logic and make
UDF consumer part of it, but it turns out that's not easy and break many
things, it's better to leave the refactor job to someone who totally understand
it, like you. I would wait for you refactor work.
BTW: It take half of the total memory as upper boundary, but i guess it
does not make any different :)
> Add topK operator for DataSet
> -----------------------------
>
> Key: FLINK-2549
> URL: https://issues.apache.org/jira/browse/FLINK-2549
> Project: Flink
> Issue Type: New Feature
> Components: Core, Java API, Scala API
> Reporter: Chengxiang Li
> Assignee: Chengxiang Li
> Priority: Minor
>
> topK is a common operation for user, it would be great to have it in Flink.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
