Hi everyone. During investigation FlinkOperator’s functionally I’ve faced follow issue: Upgrade mode is set to

last-state

. However when I changed the parallelism job master has failed once during startup, because it couldn’t reschedule state from latest checkpoint and then the job has been started without any state by operator. And I don’t see anything in logs what would explain such behaviour. Does anyone faced anything similar? I would be curious to know if it’s a feature or bug. And could be the behaviour configured to fail job in such cases?