[
https://issues.apache.org/jira/browse/FLINK-146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-146:
--------------------------------
Component/s: Scala API
Java API
Description:
The new Java API does not allow to specify sorted output.
This feature will require support for RangePartitioning: FLINK-7, FLINK-8
was:
The Pact API allows to specify sorted output.
This feature is currently not working due to open issues with range
partitioning.
However, the user is not notified that this is not working.
I suggest that we address this issue as follows:
- As a quick fix, add a compiler exception for jobs that request output sorting.
- As a partial solution, enable locally sorted output (and fully sorted on
sinks with DOP 1).
- Finally, enable sorted output via range partitioning.
---------------- Imported from GitHub ----------------
Url: https://github.com/stratosphere/stratosphere/issues/146
Created by: [fhueske|https://github.com/fhueske]
Labels: bug, core,
Milestone: Release 0.4
Assignee: [fhueske|https://github.com/fhueske]
Created at: Thu Oct 10 15:30:14 CEST 2013
State: open
Issue Type: New Feature (was: Bug)
> Sorted output not working
> -------------------------
>
> Key: FLINK-146
> URL: https://issues.apache.org/jira/browse/FLINK-146
> Project: Flink
> Issue Type: New Feature
> Components: Distributed Runtime, Java API, Scala API
> Reporter: Fabian Hueske
> Labels: github-import
> Fix For: pre-apache
>
>
> The new Java API does not allow to specify sorted output.
> This feature will require support for RangePartitioning: FLINK-7, FLINK-8
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
