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-7541) Redistribute operator state using OperatorID
Date Tue, 26 Sep 2017 07:43:00 GMT

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

ASF GitHub Bot commented on FLINK-7541:

Github user tillrohrmann commented on the issue:

    Please don't close this PR, because the commit was reverted. Using `Multimap#get` in the
`StateAssignmentOperation` makes the `OperatorSubtaskState` not serializable. The `WindowCheckpointingITCase`
caught the problem.

> Redistribute operator state using OperatorID
> --------------------------------------------
>                 Key: FLINK-7541
>                 URL: https://issues.apache.org/jira/browse/FLINK-7541
>             Project: Flink
>          Issue Type: Improvement
>            Reporter: Piotr Nowojski
>            Assignee: Piotr Nowojski
> Currently StateAssignmentOperation relays heavily on the order of new and old operators
in the task. It should be changed and it should relay more on OperatorID.

This message was sent by Atlassian JIRA

View raw message