Skip to content

Dependency clashes on newer version Flink if "flink-avro:1.19.2" is in classpath #371

@bing-hsu

Description

@bing-hsu

software.amazon.glue:schema-registry-flink-serde:1.1.23 is compiled against org.apache.flink:flink-avro:1.12.2.

When using a Flink runtime of a newer version - 1.19.2 with org.apache.flink:flink-avro:1.19.2 in the classpath, job fails reporting java.lang.NoSuchMethodError:

Caused by: java.lang.NoSuchMethodError: 'org.apache.avro.io.BinaryEncoder com.amazonaws.services.schemaregistry.flink.avro.GlueSchemaRegistryAvroSerializationSchema.getEncoder()'
	at com.amazonaws.services.schemaregistry.flink.avro.GlueSchemaRegistryAvroSerializationSchema.serialize(GlueSchemaRegistryAvroSerializationSchema.java:106)
	at org.apache.flink.connector.kafka.sink.KafkaRecordSerializationSchemaBuilder$KafkaRecordSerializationSchemaWrapper.serialize(KafkaRecordSerializationSchemaBuilder.java:348)
	at org.apache.flink.connector.kafka.sink.KafkaWriter.write(KafkaWriter.java:193)

If org.apache.flink:flink-avro:1.19.2 is removed then job works as expected.

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions