Serialization Bug ?

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Serialization Bug ?

Matthias J. Sax-2
Hi,

today, the following question appeared on SO:
https://stackoverflow.com/questions/34596005/how-to-make-a-variable-available-to-all-of-the-taskmanagers-in-apache-flink

This sounds like a bug to me... MyPartitioner seems not to get
serialized and deserialized correctly, resulting in an empty list of
member mykey or null if mykey is declared static.

Can anyone verify?

-Matthias


signature.asc (836 bytes) Download Attachment
Reply | Threaded
Open this post in threaded view
|

Re: Serialization Bug ?

Robert Metzger
The user was able to resolve the issue by disabling the closure cleaner.
Apparently, the closure cleaner is stumbling across the static variable.

@Aljoscha: I think you've added the ClosureCleaner, what do you think about
this?

On Tue, Jan 5, 2016 at 4:09 PM, Matthias J. Sax <[hidden email]> wrote:

> Hi,
>
> today, the following question appeared on SO:
>
> https://stackoverflow.com/questions/34596005/how-to-make-a-variable-available-to-all-of-the-taskmanagers-in-apache-flink
>
> This sounds like a bug to me... MyPartitioner seems not to get
> serialized and deserialized correctly, resulting in an empty list of
> member mykey or null if mykey is declared static.
>
> Can anyone verify?
>
> -Matthias
>
>