Re: Flink Pojo Serialization for Map Values

2020-07-16 Thread Theo Diefenthal
20 20:57:09 Betreff: Re: Flink Pojo Serialization for Map Values Theo, thank you for clarification and code examples. I was actually suspectign that this is becase the Java type erasure.s The thing that bothers me though is fact that Flink was failing over to Kryo silently in my case. Without any infor

Re: Flink Pojo Serialization for Map Values

2020-07-16 Thread KristoffSC
Theo, thank you for clarification and code examples. I was actually suspectign that this is becase the Java type erasure.s The thing that bothers me though is fact that Flink was failing over to Kryo silently in my case. Without any information in the logs. And actually we found it just by luck.

Re: Flink Pojo Serialization for Map Values

2020-07-15 Thread Theo Diefenthal
is for Flink 1.9. I read somewhere that Flink now has a new type system somehow, somewhere but I didn't check this out yet and have no idea what changed. Best regards Theo ----- Ursprüngliche Mail - Von: "KristoffSC" An: "user" Gesendet: Montag, 13. Juli 2020 2

Re: Flink Pojo Serialization for Map Values

2020-07-15 Thread KristoffSC
Hi, Any ideas about that one? -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Flink Pojo Serialization for Map Values

2020-07-13 Thread KristoffSC
Hi, I would like to ask Flink Pojo Serialziation described in [1] I have a case where my custom event source produces Events described by Pojo: public class DataPoint { public long timestamp; public double value; public BadPojo badPojo = new BadPojo(); public Data