Hi,

I tried running a stop with savepoint on my Flink job, which includes
numerous Flink SQL streams. While running the command I used `-d` to drain
all streams with MAX_WATERMARK.

Looking at the Flink UI, all sources successfully finished, yet all Flink
SQL streams were in a Running state, and none of them transitioned although
none of them were in a state of backpressure at all. I waited around 10
minutes, yet nothing seemed to change.

My question is, do Flink SQL streams support draining the streams before
stopping?

-- 
Best Regards,
Yuval Itzchakov.

Reply via email to