Я восстанавливаю свою работу с точки сохранения 1,8 ГБ, а затем сразу же создаю новую точку сохранения, размер которой составляет ~ 50 МБ. Откуда у меня штат go?

Question

Я использую команду:

flink run jarfile.jar -s savepoint

Обратите внимание, что я не использую опцию -n, поэтому не ожидаю потери данных в этом отношении. Более того, я следую инструкциям, данным руководством по сохранению , то есть присваиваю UID каждому оператору.

Я использую Flink версии 1.9.1.