flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Till Rohrmann (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-7541) Redistribute operator state using OperatorID
Date Tue, 26 Sep 2017 07:12:00 GMT

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

Till Rohrmann commented on FLINK-7541:

Please don't close this JIRA, because the commit was reverted with 142bde0e8410224de821cefe3876afb8bc6aaf1a.
The reason was that the usage of {{Multimap}} cause the {{OperatorSubtaskState}} to be no
longer serializable (more specifically {{ArrayListMultimap#get}} returns a {{Collection}}
which is not {{Serializable}}). This was visible due to the failing {{WindowCheckpointingITCase}}.

> 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