Flink: Можно ли предоставить или назначить отметку времени для контрольной точки?

Question

Flink: Можно ли указать или назначить отметку времени для папки контрольных точек, например, добавив отметку времени последней контрольной точки в папку с именем с идентификатором задания? Можно ли присвоить индивидуальное имя внешней контрольной точке каждой работы? Если да, то как?

Answer 1

Похоже, вы можете установить только root путь к каталогу , а затем данные chekpoint записываются следующим образом.

/user-defined-checkpoint-dir
    /{job-id}
        |
        + --shared/
        + --taskowned/
        + --chk-1/
        + --chk-2/
        + --chk-3/
        ...