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
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.
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
Hi,
Any ideas about that one?
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
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