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-4731) HeapKeyedStateBackend restorig broken for scale-in
Date Tue, 04 Oct 2016 09:08:20 GMT

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

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

GitHub user StefanRRichter opened a pull request:

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

    [FLINK-4731] Bugfix for HeapKeyedStateBackend scale-in and additional tests in RescalingITCase

    Restoring the HeapKeyedStateBackend was broken in case that parallelism is reduced. The
restore method was overwriting previously restored state.
    
    Added scale-in testing to the RescalingITCase to catch problems like this in the future.


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

    $ git pull https://github.com/StefanRRichter/flink stream-keyed-state

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

    https://github.com/apache/flink/pull/2584.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 #2584
    
----
commit 12a981ee478ec6cd29d768c5e4166aad97e6e06b
Author: Stefan Richter <s.richter@data-artisans.com>
Date:   2016-10-02T12:15:48Z

    [hotfix] Make KeyGroupsStateHandle implement StreamStateHandle

commit 91f76867df790eba9fec793f4e276b7b05aebb6c
Author: Stefan Richter <s.richter@data-artisans.com>
Date:   2016-10-02T09:30:59Z

    [hotfix] Minor cleanup in FlinkKafkaConsumerBase and Test

commit a7614c1b583f220dcc78a8130494552bc085a13f
Author: Stefan Richter <s.richter@data-artisans.com>
Date:   2016-10-02T12:19:37Z

    [FLINK-4730] Introducing CheckpointMetaData

commit c29804d95e5baa52f6ce47a7a1546ec3797fa9d2
Author: Stefan Richter <s.richter@data-artisans.com>
Date:   2016-10-02T14:56:41Z

    [FLINK-4731] Bugfix for HeapKeyedStateBackend scale-in and additional tests in RescalingITCase

----


> HeapKeyedStateBackend restorig broken for scale-in
> --------------------------------------------------
>
>                 Key: FLINK-4731
>                 URL: https://issues.apache.org/jira/browse/FLINK-4731
>             Project: Flink
>          Issue Type: Bug
>          Components: State Backends, Checkpointing
>            Reporter: Stefan Richter
>            Assignee: Stefan Richter
>
> Restoring the HeapKeyedStateBackend is broken in case that parallelism is reduced. The
restore method is overwriting previously restored state.
> We should also add scale-in testing to the RescalingITCase.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message