flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Robert Metzger <rmetz...@apache.org>
Subject Re: Serialization Bug ?
Date Wed, 06 Jan 2016 16:00:38 GMT
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 <mjsax@apache.org> 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
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message