Re: Problems with type erasure

2020-06-22 Thread Vincenzo Pronestì
link tries to create a new transformation based on the information of `delays`. Best,  Yun --Original Mail -- *Sender:*Vincenzo Pronestì *Send Date:*Mon Jun 22 19:02:05 2020 *Recipients:*flink-user *Subject:*Problems with type erasure

Problems with type erasure

2020-06-22 Thread Vincenzo Pronestì
Hi there, I need to execute the following code: 72: KeyedStream, String> keyedDelays = delays 73: .flatMap(new Query1FlatMap())74: .keyBy(item -> item.f0); but I keep getting this error message: The program finished with the following exception: The return type