flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Timo Walther <twal...@apache.org>
Subject Re: Java 8 and keyBy in 1.0.0
Date Wed, 30 Mar 2016 10:39:25 GMT
I will assign this issue to me and fix it soon, if that's ok?

Regards,
Timo


On 30.03.2016 11:30, Stephan Ewen wrote:
> Looks like something we should fix though. Probably just needs a case 
> distinction in the TypeExtractor.
>
> @Andrew, can you post the stack trace into the me linked issue?
>
> We'll try to get at it until the next release...
>
> On Wed, Mar 30, 2016 at 10:58 AM, Chesnay Schepler <chesnay@apache.org 
> <mailto:chesnay@apache.org>> wrote:
>
>     based on https://issues.apache.org/jira/browse/FLINK-3138 this is
>     not supported for non-static methods.
>
>
>     On 30.03.2016 10:33, Andrew Ge Wu wrote:
>>     Hi,
>>
>>     This is not very obvious and looks like a bug.
>>
>>     I have a lambda expression to get key from objects in stream:
>>
>>     *This works:*
>>     stream.keyBy(value -> value.getId())
>>
>>     *This does not:*
>>     stream.keyBy(myClass::getId)
>>
>>     Exception:
>>
>>     Exception in thread "main"
>>     java.lang.ArrayIndexOutOfBoundsException: -1
>>     at
>>     org.apache.flink.api.java.typeutils.TypeExtractor.getUnaryOperatorReturnType(TypeExtractor.java:294)
>>     at
>>     org.apache.flink.api.java.typeutils.TypeExtractor.getKeySelectorTypes(TypeExtractor.java:253)
>>     at
>>     org.apache.flink.api.java.typeutils.TypeExtractor.getKeySelectorTypes(TypeExtractor.java:246)
>>     at
>>     org.apache.flink.streaming.api.datastream.KeyedStream.<init>(KeyedStream.java:87)
>>     at
>>     org.apache.flink.streaming.api.datastream.DataStream.keyBy(DataStream.java:241)
>>
>>
>>     Can someone confirm this? or is there a better way to do it?
>>
>>
>>     Thanks!
>>
>>
>>     Andrew
>>
>>     Confidentiality Notice: This e-mail transmission may contain
>>     confidential or legally privileged information that is intended
>>     only for the individual or entity named in the e-mail address. If
>>     you are not the intended recipient, you are hereby notified that
>>     any disclosure, copying, distribution, or reliance upon the
>>     contents of this e-mail is strictly prohibited and may be
>>     unlawful. If you have received this e-mail in error, please
>>     notify the sender immediately by return e-mail and delete all
>>     copies of this message. 
>
>


Mime
View raw message