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

ASF GitHub Bot commented on FLINK-6899:
---------------------------------------

GitHub user tillrohrmann opened a pull request:

    https://github.com/apache/flink/pull/4107

    [FLINK-6899] [state] Create correctly sized state array in 
NestedMapsStateTable

    cc @StefanRRichter 


You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/tillrohrmann/flink fixNestedMapsStateTable

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/flink/pull/4107.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #4107
    
----
commit 5d1861539a70475b1652483161a0e66aa95afb53
Author: Till Rohrmann <trohrm...@apache.org>
Date:   2017-06-12T13:21:47Z

    [FLINK-6899] [state] Create correctly sized state array in 
NestedMapsStateTable

----


> Wrong state array size in NestedMapsStateTable
> ----------------------------------------------
>
>                 Key: FLINK-6899
>                 URL: https://issues.apache.org/jira/browse/FLINK-6899
>             Project: Flink
>          Issue Type: Bug
>          Components: State Backends, Checkpointing
>    Affects Versions: 1.3.0, 1.4.0
>            Reporter: Till Rohrmann
>            Assignee: Till Rohrmann
>            Priority: Minor
>             Fix For: 1.4.0
>
>
> The {{NestedMapsStateTable}} initializes the internal state array with a 
> wrong size which leads to a waste of memory. We should initialize the array 
> with the number of key groups of the assigned range instead of the max 
> parallelism.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Reply via email to