Блог

Главная - Вопросы по программированию - java.io.InvalidClassException: org.apache.flink.api.common.operators.ResourceSpec; несовместимые типы для полевых процессоров

java.io.InvalidClassException: org.apache.flink.api.common.operators.ResourceSpec; несовместимые типы для полевых процессоров

#apache-beam #flink-streaming

#apache-beam #flink-потоковая передача

Вопрос:

Я использую Beam версии 1.24 с кластером сеансов Flink версии 1.11 с beam-runners-flink-1.9. Когда я запускаю задание с удаленным FlinkRunner в потоковом режиме, я получаю следующую ошибку. Любые идеи будут оценены. Я не мог поместить всю трассировку стека, поскольку StackOverflows не позволил бы мне опубликовать всю трассировку стека.

Спасибо, Рао.

Вызвано: java.io.InvalidClassException: org.apache.flink.api.common.operators.ResourceSpec; несовместимые типы для полевых процессоров

Ответ №1:

Это произошло из-за несовместимости версий Flink и Beam; использование артефакта Maven, соответствующего версии сервиса, решило проблему. Вот фрагмент Maven:

 <dependency>
        <groupId>org.apache.beam</groupId>
        <artifactId>beam-runners-flink-1.11</artifactId>
        <version>2.25.0</version>
</dependency>