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
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
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
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
Hi All
I have a simple avro file
{"namespace": "com.kpn.datalab.schemas.omnicrm.contact_history.v1",
"type": "record",
"name": "contactHistory",
"fields": [
{"name": "events", "type": {"type":"array",
"items": "bytes"}},
{"name": "krn", "type": "string"}
]
