I will also have a look at this issue.
Am 11/10/16 um 09:10 schrieb Chesnay Schepler:
Yes, i think a JIRA issue would be good for this.
On 11.10.2016 08:42, Martin Junghanns wrote:
Shall I open an issue for that?
The Exception gets thrown when using
RichFlatJoinFunction or RichFlatMapFunction (updated the Gist)
and the first field of the tuple is an array type.
I can look into it once the issue is there.
Cheers,
Martin
On 10.10.2016 13:39, Chesnay Schepler wrote:
Hello Martin,
Could you include the error you are getting?
Regards,
Chesnay
On 10.10.2016 13:31, Martin Junghanns wrote:
Hi,
I ran into a problem when using generic arrays in a tuple. I wrote
a minimal program to reproduce the error [1].
The problem seems to be related to the order of tuple fields. When
I switch Tuple2<K[], K> to Tuple2<K, K[]> and perform the join on
field 0, everything works as expected.
Using Flink 1.1.2.
Cheers,
Martin
[1] https://gist.github.com/s1ck/37aefb19198cd01a8b998fab354c2cfd
--
Freundliche Grüße / Kind Regards
Timo Walther
Follow me: @twalthr
https://www.linkedin.com/in/twalthr
