Hi! I have two streams that I connect and call keyBy after.
I put some debugging code in the bKeySelector. Turns out, it gets called twice from different areas. Stacktrace here: https://gist.github.com/JonasGroeger/8ce218ee1c19f0639fa990f43b5f9e2b It contains 1 package which gets keyed twice for some reason from The case class MyPackage has mostly Ints and Strings. The IP addresses however are done with references: Now for some reason these are on the second call of the keying function which looks like this: Also all Arrays have another reference set. Before and after: ) How come? -- 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-tp10907.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
