It's after a checkpoint failure. I don't know if that includes a restore from a checkpoint.
I'll take some screenshots when the jobs hit the failure again. All of my currently running jobs are healthy right now and haven't hit a checkpoint failure. On Sun, Jul 18, 2021 at 11:34 PM Dawid Wysakowicz <dwysakow...@apache.org> wrote: > 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. > >
