FLINKは

Question

私は

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) 

は、誰かが何が間違っている私に教えてくださいすることができ https://ci.apache.org/projects/flink/flink-docs-release-0.8/programming_guide.html#introduction

私はIDEで実行している次のエラーを取得するdoucmentationを使用して、このサンプルプログラムを作成した日食。

ありがとうございます。

Answer 1

このドキュメントページはバージョン0.8です。更新されたバージョンで再試行してください（1.1.2が最新です）。

この問題は、Eclipseから使用しているクラスパスに関連している可能性があります。 Eclipseから変更し、assemblyモジュールを使用する必要があります。最近のバージョンでは、適切なモジュールはmainRunnerと呼ばれています。