Java.lang.ClassNotFoundException: org.apache.flink.connector.base.source.reader.RecordEmitter ⇐ JAVA

[Anonymous]

Я пытался запустить пример задания Flink из документации Apache Flink подсчета слов, но уже некоторое время получаю эту ошибку, похоже, это проблема с зависимостями, но пытался изменить POM-файл, но все равно безуспешно, ниже это мой ПОМ

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

org.apache.flink
flink-core
1.20.0


org.apache.flink
flink-streaming-java
1.20.0


org.apache.flink
flink-walkthrough-common
1.20.0


org.apache.flink
flink-clients
1.20.0


org.apache.flink
flink-connector-kafka
3.3.0-1.20


log4j
log4j
1.2.17


mysql
mysql-connector-java
8.0.33



org.apache.flink
flink-connector-jdbc
3.2.0
system
${project.basedir}/src/main/resources/lib/flink-connector-jdbc-3.2.0.jar

Я пробовал изменить POM-файл и ожидал, что этот код запустится, но ничего не получилось

Подробнее здесь: https://stackoverflow.com/questions/793 ... rce-reader