austince edited a comment on pull request #15348:
URL: https://github.com/apache/flink/pull/15348#issuecomment-806171998
👍🏼 it does not seem possible to be able to detect that scenario from the
information available in a CompletedCheckpoint, nor is it possible to detect
the user-error scenarios that I noted with the given information, so for all
cases I would lean towards:
* logging this
* not updating the max parallelism if the StateAssignmentOperation attempts
to lower it in reactive mode
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?
--
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]
