flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Timo Walther <twal...@apache.org>
Subject Re: Type problem in RichFlatMapFunction when using GenericArray type
Date Tue, 11 Oct 2016 16:13:41 GMT
I identified the problem and opened a issue for it: 
https://issues.apache.org/jira/browse/FLINK-4801


Am 11/10/16 um 15:31 schrieb Timo Walther:
> 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


Mime
View raw message