I was refactoring my solution a bit and tried to make my stateful transform to work on simple case classes and I got this exception: https://pastebin.com/x4xADmvL . I'd like to understand the rationale behind this as I think carefully choosing the keys would be very important in order for the work to be properly distributed.
Thanks!
