austince commented on pull request #15348:
URL: https://github.com/apache/flink/pull/15348#issuecomment-806116899


   > After a discussion with @tillrohrmann we also found another issue:
   > If the StateAssignmentOperation is able to set the maxParallelism, then 
the reactive mode cannot make a correct decision as to what the actual max 
parallelism is. It will come up with some initial parallelism, but this can 
easily exceed the maxParallelism of the savepoint.
   
   Good point – in a follow up with @tillrohrmann, the workaround, for now, 
seems to be ensuring that the StateAssignmentOperation does not decrease the 
`maxParallelism` that has been declared during scheduling (either by the user 
or the system). In the longer term, we'll want to move restoring 
`maxParallelism` from state to somewhere else, perhaps before scheduling.


-- 
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