subject:"Keyed function type erasure problem."

Re: Keyed function type erasure problem.

2017-09-14 Thread yunfan123

Thanks -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: Keyed function type erasure problem.

2017-09-14 Thread Fabian Hueske

Hi, The problem is that Flink cannot determine the key type produced by the KeySelector because the type is a generic. The type information is lost at runtime due to Java's type erasure. You can try to implement the ResultTypeQueryable interface with the KeySelector and tell Flink the key type di

Keyed function type erasure problem.

2017-09-11 Thread yunfan123

Just small change from PojoExample: PojoExample.java public class PojoExample { private SelectorContainer selectorContainer; // KeySelector class like this can't be used in flink !!!