Re: How to figure out what's the size of ListState?

2023-05-27 Thread Amir Hossein Sharifzadeh
Thank you Yun for your reply. Yes, I did the same thing and posted my solution here: https://stackoverflow.com/questions/76308686/how-to-figure-out-whats-the-size-of-liststate?noredirect=1#comment134577594_76308686 Best, Anir On Wed, May 24, 2023 at 5:13 AM Yun Tang wrote: > Hi Amir, > > For

Re: How to figure out what's the size of ListState?

2023-05-24 Thread Yun Tang
Hi Amir, For the current Flink, you have to iterator the returned Iterable of ListState#get(). Why Flink lacks an API to get the size of listState directly? This is because Flink leverages RocksDB's merge operator [1] for high-performance listState#add [2], that is to say, we would not even

How to figure out what's the size of ListState?

2023-05-23 Thread Amir Hossein Sharifzadeh
Dear Flink Dev team, It's about a while since I am dealing with an issue that can't figure out myself. I spent quite a lot of time trying to solve the problem myself, but I feel stuck. I explained the problem statement and the issue here: