|
|
Hi,
Any thoughts of why would I get such an error when trying to run within eclipse a simple (i.e., any) flink program.
...I did start the local cluster before - where I was able to run the job...but after that it did not work anymore to run flink from eclipse.
Exception in thread "main" java.lang.NoSuchFieldError: WEB_ARCHIVE_COUNT
at org.apache.flink.runtime.jobmanager.JobManager$.createJobManagerComponents(JobManager.scala:2535)
at org.apache.flink.runtime.minicluster.LocalFlinkMiniCluster.startJobManager(LocalFlinkMiniCluster.scala:143)
at org.apache.flink.runtime.minicluster.FlinkMiniCluster$$anonfun$1.apply(FlinkMiniCluster.scala:328)
at org.apache.flink.runtime.minicluster.FlinkMiniCluster$$anonfun$1.apply(FlinkMiniCluster.scala:322)
at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
at scala.collection.immutable.Range.foreach(Range.scala:141)
at scala.collection.TraversableLike$class.map(TraversableLike.scala:244)
at scala.collection.AbstractTraversable.map(Traversable.scala:105)
at org.apache.flink.runtime.minicluster.FlinkMiniCluster.start(FlinkMiniCluster.scala:322)
at org.apache.flink.runtime.minicluster.FlinkMiniCluster.start(FlinkMiniCluster.scala:313)
at org.apache.flink.client.LocalExecutor.start(LocalExecutor.java:116)
at org.apache.flink.client.LocalExecutor.executePlan(LocalExecutor.java:176)
at org.apache.flink.api.java.LocalEnvironment.execute(LocalEnvironment.java:91)
at org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:921)
at org.apache.flink.api.java.DataSet.collect(DataSet.java:413)
at org.apache.flink.api.java.DataSet.print(DataSet.java:1652)
at org.bdcourse.BatchJob.main(BatchJob.java:60)
|
Locked
