Hi.

We're doing something bad with our Flink state.  We just launched a feature
that creates very big values (lists of objects that we append to) in
MapState.

Our checkpoints time out (10 minutes).  I'm assuming the values are too
big.  Backpressure is okay and cpu+memory metrics look okay.

Questions

1. Is there an easy tool for inspecting the Flink state?

I found this post about drilling into Flink state
<https://flink.apache.org/news/2020/01/29/state-unlocked-interacting-with-state-in-apache-flink.html>.
I was hoping for something more like a CLI.

2. Is there a way to break down the time spent during a checkout if it
times out?

Thanks!
- Dan

Reply via email to