Re: keyBy called twice. Second time, INetAddress and Array[Byte] are empty

Hey Jamie, It turns out you were right :) I wrote my own implementation of IPAddress and then it worked. -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/keyBy-called-twice-Second-time-INetAddress-and-Array-Byte-are-empty-tp10907p11179.html S

Re: keyBy called twice. Second time, INetAddress and Array[Byte] are empty

Hi Jonas, The issue has to do with serializing/deserializing InetAddress. If you look at the InetAddress class the data members that hold the actual ip address are transient fields and such are not serialized/deserialized in the way that you would expect. This is what is causing the issue. I su

Re: keyBy called twice. Second time, INetAddress and Array[Byte] are empty

So I created a minimal working example where this behaviour can still be seen. It is 15 LOC and can be downloaded here: https://github.com/JonasGroeger/flink-inetaddress-zeroed To run it, use sbt: If you don't want to do the above fear not, here is the code: For some reason, java.net.InetAddress