Java Flink NoClassDefFoundError org/apache/flink/shaded/guava30/com/google/common/io/Closer ⇐ JAVA

[Anonymous]

У меня есть приложение Java 21, которое использует зависимости Apache Flink (версия 1.20.0) для фильтрации потока Kafka.
Когда я пытаюсь выполнить свою программу, я получаю следующую ошибку: п>

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

[flink-pekko.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Wikimedia Recent Change Events -> Filter -> Sink: Writer -> Sink: Committer (12/20) (b06737fae3a29dd6d5031f24d0e01683_cbc357ccb763df2852fee8c4fc7d55f2_11_0) switched from INITIALIZING to FAILED on 114b44f3-53af-41a6-bc97-a040192436ae @ localhost (dataPort=-1).
java.lang.NoClassDefFoundError: org/apache/flink/shaded/guava30/com/google/common/io/Closer
at org.apache.flink.connector.kafka.sink.KafkaWriter.(KafkaWriter.java:109)
at org.apache.flink.connector.kafka.sink.KafkaSink.createWriter(KafkaSink.java:111)
at org.apache.flink.connector.kafka.sink.KafkaSink.createWriter(KafkaSink.java:57)
at org.apache.flink.api.connector.sink2.Sink.createWriter(Sink.java:78)
at org.apache.flink.streaming.runtime.operators.sink.StatefulSinkWriterStateHandler.createWriter(StatefulSinkWriterStateHandler.java:122)
at org.apache.flink.streaming.runtime.operators.sink.SinkWriterOperator.initializeState(SinkWriterOperator.java:148)
at org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.initializeOperatorState(StreamOperatorStateHandler.java:147)
at org.apache.flink.streaming.api.operators.AbstractStreamOperator.initializeState(AbstractStreamOperator.java:294)
at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:106)
at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreStateAndGates(StreamTask.java:858)
at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$restoreInternal$5(StreamTask.java:812)
at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)
at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:812)
at org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:771)
at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:970)
at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:939)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:763)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575)
at java.base/java.lang.Thread.run(Thread.java:1583)
Caused by: java.lang.ClassNotFoundException: org.apache.flink.shaded.guava30.com.google.common.io.Closer
... 19 more

Чтобы решить эту проблему, я попытался добавить следующую зависимость в свой pom.xml:

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

        
org.apache.flink
flink-shaded-guava
31.1-jre-17.0
compile

Но я все равно получаю ту же ошибку.

Подробнее здесь: https://stackoverflow.com/questions/790 ... ogle-commo