Hi,
I have specified operator uuid for all of my operator in Flink job and
triggered a savepoint and `_metafile` got generated. When I use state processor
APIs to read the saved snapshot and try to read the mapping, I am not able to
resolve which operator id map to which operator in my code.
1
Hi,
Can anyone suggest if PyFlink Data Stream APIs (available from Flink 1.12) are
being properly tested and used in any production environment/use-case without
any issue and gives expected performance?
Hi,
We are trying to save checkpoints for one of the flink job running in Flink
version 1.9 and tried to resume the same flink job in Flink version 1.11.2. We
are getting the below error when trying to restore the saved checkpoint in the
newer flink version. Can
Cannot map checkpoint/savepoint
