Do you mean a failed checkpoint, or do you mean that it happens after a restore from a checkpoint? If it is the latter then this is kind of expected, as watermarks are not checkpointed and they need to be repopulated again.
Best, Dawid On 19/07/2021 07:41, Dan Hill wrote: > After my dev flink job hits a checkpoint failure (e.g. timeout) and > then has successful checkpoints, the flink job appears to be in a bad > state. E.g. some of the operators that previously had a watermark > start showing "no watermark". The jobs proceed very slowly. > > Is there documentation for this state? It seems weird to me that > operators would not show watermarks anymore.
OpenPGP_signature
Description: OpenPGP digital signature
