Github user zentol commented on the issue:

    https://github.com/apache/flink/pull/3117
  
    @ShashwatRastogi-Reflektion 
    
    1. For each task to load from the savepoint S1:
    * Determine the existing hash by searching for the task ID in the logs/UI
    * Set the uidHash for that task to that value via 
`SingleOutputStreamOperator#setUidHash`
    
    2. For each task:
    * Set the uid to whatever value you wish in the future to use via 
`SingleOutputStreamOperator#setUid`
    
    3. Resume the job from the savepoint S1.
    4. Create a new savepoint S2, and remove all calls to `setUidHash`
    5. Resume the job from the savepoint S2.


---

Reply via email to