AHeise commented on pull request #13735:
URL: https://github.com/apache/flink/pull/13735#issuecomment-722914106


   > Thanks for updating the PR, LGTM.
   > 
   > I'm only concerned about changing the partitioner upon restart. For 
example, if the job is modified so that DOP of upstream is no longer equal to 
DOP of the downstream; then it switches from `Forward` to `Rebalance` IIUC. 
Which will break state distribution, so it should be prohibited.
   > If that's a valid concern I'd approach it in a different effort.
   
   The concern is valid. I'm adding a check in the second PR then.


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Reply via email to