We're attempting to upgrade our 1.3.2 cluster and jobs to 1.4.0. When submitting jobs to the 1.4.0 Kafka cluster, they fail with a Kryo registration error.
My jobs are consuming from Kafka topics with messages in Avro format. The avro schemas are registered with a Confluent avro schema registry. For ingestion, we've been using the KafkaDeserializerWrapper class from this pull request: https://github.com/apache/flink/pull/2705 In the pom.xml, I added a new dependency for flink-avro, and upgraded all other maven dependencies to version 1.4.0 Here's the error: Here are the dependencies: -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
