You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/03 12:34:00 UTC

[jira] [Commented] (FLINK-5480) User-provided hashes for operators

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

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

Github user ShashwatRastogi-Reflektion commented on the issue:

    https://github.com/apache/flink/pull/3117
  
    Hey @uce, @StefanRRichter 
    
    I too have a flink job running in production where operators doesn't have uids. Now, I have to add new operators and the job doesn't restart from savepoint. 
    I came across this PR, and I tried setting the uid hash of the operator-chain before adding a new operator but still loading from savepoint doesn't work.
    
    I'm sorry to bother you, and I know this has been a long closed PR, but can you help me out in figuring out how to restart from savepoint when we don't have uids set initially.
    
    Thank you so much. :)
    PS. Sorry to spam here.


> User-provided hashes for operators
> ----------------------------------
>
>                 Key: FLINK-5480
>                 URL: https://issues.apache.org/jira/browse/FLINK-5480
>             Project: Flink
>          Issue Type: Improvement
>          Components: DataStream API
>    Affects Versions: 1.2.0
>            Reporter: Stefan Richter
>            Assignee: Stefan Richter
>            Priority: Major
>             Fix For: 1.2.0, 1.3.0
>
>
> We could allow users to provided (alternative) hashes for operators in a StreamGraph. This can make migration between Flink versions easier, in case the automatically produced hashes between versions are incompatible. For example, users could just copy the old hashes from the web ui to their job.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)