zentol commented on pull request #15348: URL: https://github.com/apache/flink/pull/15348#issuecomment-806229037
> it does not seem possible to be able to detect that scenario from the information available [...] Correct. > [throw an exception] if the StateAssignmentOperation attempts to lower [the maxParallelism] in reactive mode Yes, that should be sufficient. > I think being able to detect these scenarios would require adding how the max parallelism was set to the checkpoint data, which does not seem to be worth the change. Does that sound reasonable to you? Handling that is out of scope of the PR. The solution would be to read the savepoint before the ExecutionGraph is created, extract the max parallelism for all vertices, set the maxParallelism in some form, and later assign the states to the actual vertices when the EG is created. -- 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: [email protected]
