Как работает процесс восстановления контрольной точки? - PullRequest
1 голос
/ 11 апреля 2019

Я пытаюсь узнать о процессе восстановления контрольной точки, и пока я нашел только информацию о том, как работает механизм инкрементальной контрольной точки. Обычно, когда вы говорите о процедуре резервного копирования в другом месте, вы говорите о полной операции, которая идет первой, и инкрементальной операции, которая идет после, которая представляет собой разницу между полной и инкрементной. Но здесь, когда мы говорим об инкрементной контрольной точке, мы не делаем полный снимок состояния, а сразу начинаем с инкрементного механизма. Итак, я пытаюсь понять, как это работает, когда мы используем сохранение, и у нас осталось только несколько инкрементных контрольных точек, тогда как мы можем заполнить все данные состояния, если инкрементная контрольная точка представляет только изменения от одной контрольной точки к другой.

1 Ответ

1 голос
/ 11 апреля 2019

Чтобы инкрементные контрольные точки работали, Flink сохраняет для каждой контрольной точки приращения (или объекты общего состояния), необходимые для полного восстановления состояния контрольных точек. Инкрементный / разделяемый объект состояния - это фактически разница между двумя контрольными точками. В зависимости от доступа к состоянию и логики уплотнения, в наиболее экстремальных случаях это может быть только последний сделанный вами шаг или полная история изменений.

Поскольку Flink отслеживает, на какие приращения все еще ссылается контрольная точка, он также знает, когда приращение больше не требуется (больше нет ссылок на него). Если это произойдет, то соответствующий шаг будет удален.

...