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 <mj...@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 > >
