java .lang.IncompatibleClassChangeError При запуске программы Flink table-api в кластере

Question

Я пытаюсь запустить программу Flink table-api в локальном кластере, где я получаю эту ошибку, но не в своей среде IDE, где она работает нормально, я пытался сделать предоставляемую область зависимостей / компилировать без различий.

java.lang.IncompatibleClassChangeError: Found interface org.apache.flink.table.api.java.StreamTableEnvironment, but class was expected

Я использую Flink 1.8.0

Кто-нибудь может мне помочь здесь? Заранее спасибо.

Answer 1

Вы уверены, что используете согласованную версию в своих зависимостях и кластере? Подобные исключения обычно указывают на смешивание разных версий Flink.