Thanks for the quick reply looks like Chesnay Schepler already found the ticket
https://issues.apache.org/jira/browse/FLINK-3138 <https://issues.apache.org/jira/browse/FLINK-3138> with status: Of course if it would be great if this can be fixed soon, but this can be a bit more obvious somewhere. Thanks! Andrew > On 30 Mar 2016, at 12:39, Timo Walther <twal...@apache.org> wrote: > > 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 < >> <mailto:ches...@apache.org>ches...@apache.org <mailto:ches...@apache.org>> >> wrote: >> based on https://issues.apache.org/jira/browse/FLINK-3138 >> <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. >> >> > -- 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.
