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


(???)


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


(???)

(???)


Schema evolution


(???)

(???)

(???)

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





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



(change)

(change)

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


(???)

(???)


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





...