[FLINK-7] [GitHub] Enable Range Partitioner

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Fix Version/s: 1.0.0
• Component/s: Runtime / Coordination
• Labels: pull-request-available
• Assignee: Chengxiang Li
• Reporter: GitHub Import
• Created: 09/Jun/14 09:14
• Updated: 30/Oct/21 08:26
• Resolved: 21/Dec/15 17:48

Description

The range partitioner is currently disabled. We need to implement the following aspects:

1) Distribution information, if available, must be propagated back together with the ordering property.

2) A generic bucket lookup structure (currently specific to PactRecord).

Tests to re-enable after fixing this issue:

• TeraSortITCase
• GlobalSortingITCase
• GlobalSortingMixedOrderITCase

---------------- Imported from GitHub ----------------
Url: https://github.com/stratosphere/stratosphere/issues/7
Created by: StephanEwen
Labels: core, enhancement, optimizer,
Milestone: Release 0.4
Assignee: fhueske
Created at: Fri Apr 26 13:48:24 CEST 2013
State: open

Issue Links

• relates to: FLINK-2997 Support range partition with user customized data distribution.
• links to: GitHub Pull Request #13