flink с ошибкой scala и maven в IDE eclipse

Я создал этот пример программы, используя документацию https://ci.apache.org/projects/flink/flink-docs-release-0.8/programming_guide.html#introduction

Я получаю следующую ошибку в IDE

log4j:WARN No appenders could be found for logger (org.apache.flink.api.scala.ClosureCleaner$).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
Exception in thread "main" java.lang.RuntimeException: An error occurred while loading the local executor (org.apache.flink.client.LocalExecutor).
    at org.apache.flink.api.common.PlanExecutor.createLocalExecutor(PlanExecutor.java:161)
    at org.apache.flink.api.java.LocalEnvironment.startNewSession(LocalEnvironment.java:122)
    at org.apache.flink.api.java.LocalEnvironment.execute(LocalEnvironment.java:81)
    at org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:855)
    at org.apache.flink.api.java.DataSet.collect(DataSet.java:410)
    at org.apache.flink.api.java.DataSet.print(DataSet.java:1605)
    at org.apache.flink.api.scala.DataSet.print(DataSet.scala:1615)
    at com.sc.edl.flink.ingestion$.main(ingestion.scala:27)
    at com.sc.edl.flink.ingestion.main(ingestion.scala)
Caused by: java.lang.NoSuchMethodException: org.apache.flink.client.LocalExecutor.<init>(org.apache.flink.configuration.Configuration)
    at java.lang.Class.getConstructor0(Class.java:3082)
    at java.lang.Class.getConstructor(Class.java:1825)
    at org.apache.flink.api.common.PlanExecutor.createLocalExecutor(PlanExecutor.java:158)

Может кто-нибудь, пожалуйста, дайте мне знать, что не так.

заранее спасибо


maven scala apache-flink
person Niki    schedule 05.09.2016    source источник

Ответы (1)


arrow_upward
0
arrow_downward

Эта страница документации предназначена для версии 0.8. Повторите попытку с обновленной версией (1.1.2 является последней).

Проблема в любом случае может быть связана с путем к классам, который вы используете из Eclipse. Я считаю, что вам нужно изменить его с Eclipse и использовать модуль assembly. В последней версии правый модуль называется mainRunner.

person Chobeat    schedule 06.09.2016