I would be useful if the documentation warned what type of equality it expected of values used as keys in keyBy. I just got bit in the ass by converting a field from a string to a byte array. All of the sudden the windows were no longer aggregating. So it seems Flink is not doing a deep compare of arrays when comparing keys.
- Arrays values in keyBy Elias Levy
- Re: Arrays values in keyBy Aljoscha Krettek
- Re: Arrays values in keyBy Ufuk Celebi
- Re: Arrays values in keyBy Stephan Ewen