Re: [DISCUSS] FLIP-317: Upgrade Kryo from 2.24.0 to 5.5.0

2023-06-10 Thread Kurt Ostfeld
Regarding this comment: "The version in the state is the serializer version, and applies to the entire state, independent of what it contains. If you use Kryo2 for reading and Kryo5 for writing (which also implies writing the new serializer version into state), then I'd assume that a migration

Re: [DISCUSSION] Improved USER/SYSTEM exception wrapping in Flink code base

2023-06-10 Thread Teoh, Hong
Thanks for the engagement on the thread! Sorry for the late reply, was off on holidays for a bit. @Paul Thanks for linking the historical discussion. Yes I would agree that using classloading to determine if the exception type has come from a User classloader rather than System classloader