Re: NotSerializableException: DropwizardHistogramWrapper inside AggregateFunction

2019-06-17 Thread Vijay Balakrishnan
Thanks,Fabian. I got around the issue by moving the logic for the DropwizardHistogramWrapper -a non serializable class into the ProcessWindowFunction's open() function. On Fri, Jun 7, 2019 at 12:33 AM Fabian Hueske wrote: > Hi, > > There are two ways: > > 1. make the non-serializable member va

Re: NotSerializableException: DropwizardHistogramWrapper inside AggregateFunction

2019-06-07 Thread Fabian Hueske
Hi, There are two ways: 1. make the non-serializable member variable transient (meaning that it won't be serialized) and check in the aggregate call if it has been initialized or not. 2. implement your own serialization logic by overriding readObject() and writeObject() [1]. Best, Fabian [1] ht