Hi, We are stuck with an issue in Prod. Looking fo...
# troubleshooting
a
Hi, We are stuck with an issue in Prod. Looking for some help We have deployed our jobs to Prod, after few days of running fine, the task managers are failing and restarted every min with below error. We are using Flink-1.17.2 version.
Copy code
org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer [] - Kryo serializer scala extensions are not available.
Exception in thread "Thread-211" java.lang.RuntimeException: Cannot instantiate class.
    at org.apache.flink.api.java.typeutils.runtime.PojoSerializer.createInstance(PojoSerializer.java:199)
    at org.apache.flink.api.java.typeutils.runtime.PojoSerializer.deserialize(PojoSerializer.java:399)
    at org.apache.flink.api.common.typeutils.CompositeSerializer.deserialize(CompositeSerializer.java:156)
g
You might have to disable kyro serde
a
how exactly we do this? Any leads please
also this would work if you have your serdes registered and working correctly
coz if there is no serde provided thats when Flink tries to fallback on kryo I believe