Hi all, I recently migrated from 'updateStateByKey' to 'mapWithState' and now I see a huge increase of memory. Most of it is a massive "BlockGenerator" (which points to a massive "ArrayBlockingQueue" that in turns point to a huge "Object[]").
I'm pretty sure it has to do with my code, but I barely changed anything in the code. Just adapted the function. Did anyone run into this? Best regards, Udo.
