Hi everyone, I have a general question about Flink State. I have a job that use broadcast state to process data, if the job restarts does Flink “wait” for the broadcast state to be restored before processing input data or start processing immediately even before state is fully restored? If it is later one, then I’m worried that those input that got process before state got restored will have inconsistent data.

If you restart from a checkpoint or savepoint, then all state will be restored (including broadcast state) before processing resumes.

thank you