Thank you. Your suggestion is good and I benefit a lot. For my case, I
want to know the state memory size for other reasons.
When the the gc pressure is bigger, I need to limit the source or discard
some data from the source to ensure job’s running. If the state size is bigger,
I
We are using flink 1.6.2. For filesystem backend, we want to monitor
the state size in memory. Once the state size becomes bigger, we can get
noticed and take measures such as rescaling the job, or the job may fail
because of the memory.
We have tried to get the memory usage for the
