Hello Dawid
I'm interested in this discussion because I'm currently trying to upgrade
flink from 1.9 to 1.12 for a bunch of sql jobs running in production. From
what you said, this seems to be a risky operation which might corrupt the
states. Is there any recommendation to mitigate the risk?
It wo
Hi Jan,
As of now Flink does not give any guarantees for Table/SQL API savepoint
compatibility if you change the query or Flink version. Flink Table/SQL
API uses an optimizer that can apply different optimizations or
operations reordering based on the queried fields or computations that
can result
