Flink: java.lang.NoSuchMethodError: AvroSchemaConverterJAVA

Программисты JAVA общаются здесь
Ответить
Anonymous
 Flink: java.lang.NoSuchMethodError: AvroSchemaConverter

Сообщение Anonymous »

Я пытаюсь подключиться к Кафке. Когда я запускаю простой файл JAR, я получаю следующую ошибку:

Код: Выделить всё

java.lang.NoSuchMethodError: org.apache.flink.formats.avro.typeutils.AvroSchemaConverter.convertToSchema(Lorg/apache/flink/table/types/logical/LogicalType;)Lorg/apache/avro/Schema
Да, я знаю, что NoSuchMethod потенциально может означать, что существует конфликт между версиями; однако в кластере YARN не работает экземпляр Flink.
Я также пытался поиграть с pom.xml, но безуспешно

Код: Выделить всё

UTF-8
1.13.2
1.8
2.12
5.2.1
${java.version}
${java.version}




org.apache.flink
flink-sql-connector-kafka_${scala.binary.version}
${flink.version}



org.apache.flink
flink-table-planner-blink_${scala.binary.version}
${flink.version}



org.apache.flink
flink-clients_${scala.binary.version}
${flink.version}



org.apache.flink
flink-avro-confluent-registry
${flink.version}



org.apache.flink
flink-sql-avro
${flink.version}



org.apache.avro
avro
1.8.2



org.apache.flink
flink-statebackend-rocksdb_${scala.binary.version}
${flink.version}



org.apache.flink
flink-connector-jdbc_${scala.binary.version}
${flink.version}




Подробнее здесь: [url]https://stackoverflow.com/questions/69941771/flink-java-lang-nosuchmethoderror-avroschemaconverter[/url]
Ответить

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

Вернуться в «JAVA»