flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chesnay Schepler <ches...@apache.org>
Subject Re: Type problem in RichFlatMapFunction when using GenericArray type
Date Tue, 11 Oct 2016 07:10:00 GMT
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
>>>
>>
>
>


Mime
View raw message