Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

(???

Yes

Yes (unofficially)/Maybe (untested)

No (but could be done)

Very difficult/impossible


Canonical Savepoint

Aligned Checkpoint

Unaligned Checkpoint

Statebackend change




Self-contained and relocatable


State Processor API(reading)




State Processor API(writing)


Schema evolution


untested?

untested?

Flink minor (1.x → 1.y) version upgrade


(???)


Flink bug/patch (1.14.x → 1.14.y) version upgrade


(???)

(???)

Arbitrary job upgrade (changed graph shape/record types)




Job upgrade w/o changing graph shape and record types




Rescaling




...

???(???

Canonical Savepoint

Native Savepoint

Aligned Checkpoint

Unaligned Checkpoint

Statebackend change





Self-contained and relocatable



State Processor API(reading)


(change)

(

change)


State Processor API(writing)



Schema evolution


(???)

(???)

(???)

Flink minor (1.x → 1.y) version upgrade



(change)


Flink bug/patch (1.14.x → 1.14.y) version upgrade



(change)

(change)

Arbitrary job upgrade (changed graph shape/record types)



(change)

Job upgrade w/o changing graph shape and record types



(change)(change)

Rescaling





...