flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-2997) Support range partition with user customized data distribution.
Date Sat, 19 Mar 2016 09:56:33 GMT

    [ https://issues.apache.org/jira/browse/FLINK-2997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15202690#comment-15202690

ASF GitHub Bot commented on FLINK-2997:

Github user gallenvara commented on the pull request:

    @fhueske , thanks a lot for review work, codes have been modified based on your advice.
I change the second test with modifying the range boundary from `(bucketNum+1)*7,bucketNum*2+3`
to `(bucketNum+1)*(bucketNum+2)/2,bucketNum+1`. The reason for this is for the record `Tuple3(15,
5L, "Comment#9")`, it will be emitted to `partition:2` with first field and `partition:1`
with second field and the test will be failed.

> Support range partition with user customized data distribution.
> ---------------------------------------------------------------
>                 Key: FLINK-2997
>                 URL: https://issues.apache.org/jira/browse/FLINK-2997
>             Project: Flink
>          Issue Type: New Feature
>            Reporter: Chengxiang Li
> This is a followup work of FLINK-7, sometime user have better knowledge of the source
data, and they can build customized data distribution to do range partition more efficiently.

This message was sent by Atlassian JIRA

View raw message