flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Martin Junghanns <m.jungha...@mailbox.org>
Subject Type problem in RichFlatMapFunction when using GenericArray type
Date Mon, 10 Oct 2016 11:31:58 GMT
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

Mime
View raw message