Re: flink doesn't seem to serialize generated Avro pojo

2017-06-26 Thread Aljoscha Krettek
Hi Bart, Is serialisation failing in a Flink job (for example when writing to Kafka) or just in the main() method when experimenting with serialisation? Best, Aljoscha > On 26. Jun 2017, at 11:06, Bart van Deenen wrote: > > It turns out that the Flink documentation has a whole section about t

Re: flink doesn't seem to serialize generated Avro pojo

2017-06-26 Thread Bart van Deenen
It turns out that the Flink documentation has a whole section about this problem: https://goo.gl/DMs9Dx Now let's find the solution!. Bart

Re: flink doesn't seem to serialize generated Avro pojo

2017-06-22 Thread Bart van Deenen
Thanks for the explanation, at least it's a start. Bart On Thu, Jun 22, 2017, at 11:20, Stefan Richter wrote: > Hi, > > this „amazing error“ message typically means that the class of the object > instance you created was loaded by a different classloader than the one > that loaded the class in t

Re: flink doesn't seem to serialize generated Avro pojo

2017-06-22 Thread Stefan Richter
Hi, this „amazing error“ message typically means that the class of the object instance you created was loaded by a different classloader than the one that loaded the class in the code that tries to cast it. A class in Java is fully identified by the canonical classname AND the classloader that l