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