Hi
Do you specify the operatorid for all the operators?[1][2], asking this
because from the exception you gave, if you only add new operators and all
the old operators have specified operatorid, seems there would not throw
such exception.
[1]
https://ci.apache.org/projects/flink/flink-docs-stable/
Hi Matt
Have you ever configured `high-availability.cluster-id` ? If not, Flink
standalone job would first try to recover from high-availability checkpoint
store named '/default'. If there existed a checkpoint, Flink would always
restore from checkpoint disabling 'allowNonRestoredState'[1] (alw
