As answered on SO, the problem is the KeyedDeserializationSchema which is an anonymous inner class.

On 31.03.2018 20:25, Soheil Pourbafrani wrote:
I got an error in using Flink Kafka connector for producing data. I describe the problem here <https://stackoverflow.com/questions/49589643/flink-kafka-producer-object-of-class-is-not-serializable?noredirect=1#comment86188259_49589643> in Stackoverflow. Pls help

Thanks!


Reply via email to