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

[Anonymous]

Ich habe versucht, einen Beispiel-Flink-Job aus den Dokumenten von Apache Flink of Word Count auszuführen, erhalte jedoch seit einiger Zeit diesen Fehler. Es scheint ein Abhängigkeitsproblem zu sein, aber ich habe versucht, die POM-Datei zu ändern, immer noch ohne Erfolg, siehe unten ist mein POM

Code: Select all

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

Ich habe versucht, die POM-Datei zu ändern und habe erwartet, dass dieser Code ausgeführt wird, komme aber nicht weiter