Hi Arvid and Nicolaus
Thanks for the reply.
I don't think this is an issue with the user code. I'm pretty sure that the
code is serializable.
I have not used any custom serializer. And the serialization configs are
not overridden.
My guess was the problem was with order of classloading.
I am depl
This looks like you hold a reference to some outer class or
non-serializable class. Make sure that your user function is minimal (e.g.
static or top-level class) and all fields really need to be serialized
(that excludes all caches).
On Thu, Sep 2, 2021 at 3:13 PM Nicolaus Weidner <
nicolaus.weid.
Hi Praneeth,
It does look like a failure constructing the serializer. Can you share the
serialization config you use for the Kafka producer? In particular, are you
using a custom serializer?
Do you use any custom classloading configuration?
Best regards,
Nico
On Wed, Sep 1, 2021 at 11:38 PM Pran
Hi All
I am trying to run a flink scala application which reads from kafka apply some
lookup transformations and then writes to kafka.
I am using Flink Version 1.12.1
I tested it in local and it works fine. But when I try to run it on cluster
using native kubernetes integration I see weird er
