Re: Java 8 and keyBy in 1.0.0

Thanks for the quick reply looks like Chesnay Schepler already found the ticket 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 somewh

Re: Java 8 and keyBy in 1.0.0

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

Re: Java 8 and keyBy in 1.0.0

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 wrote: > based on https://

Re: Java 8 and keyBy in 1.0.0

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 -

Java 8 and keyBy in 1.0.0

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