Hi!

I have a Flink SQL job that does a few temporal joins and has been running
for over a month on regular data.  No issues.  Ran well.

I'm trying to re-run the Flink SQL job on the same data set but it's
failing to checkpoint and very slow to make progress.  I've modified some
of the checkpoint settings.

What else do I have to modify?

My data size is really small so I'm guessing it's still keeping state for
data outside the temporal join time windows.  Do I have to set Idle State
Retention Time to forget older data?

- Dan

Reply via email to