Hey,

thanks for the reply. I didn’t change the scala version, as it worked before. I 
just changed the flink version in my pom.xml thats it, a one line change.
Maybe you could elaborate a bit more, what I can do to change the scala version?

best Stephan


> On 03 Jan 2017, at 03:11, Kurt Young <ykt...@gmail.com> wrote:
> 
> Seems like you didn't setup the correct scala SDK
> 
> best,
> Kurt
> 
> On Mon, Jan 2, 2017 at 10:41 PM, Stephan Epping <stephan.epp...@zweitag.de 
> <mailto:stephan.epp...@zweitag.de>> wrote:
> Hi,
> 
> I am getting this error running my tests with 1.1.4 inside intellij ide.
> 
> java.lang.NoSuchMethodError: 
> org.apache.flink.runtime.jobmanager.JobManager$.startJobManagerActors(Lorg/apache/flink/configuration/Configuration;Lakka/actor/ActorSystem;Lscala/Option;Lscala/Option;Ljava/lang/Class;Ljava/lang/Class;)Lscala/Tuple2;
> 
>       at 
> org.apache.flink.test.util.ForkableFlinkMiniCluster.startJobManager(ForkableFlinkMiniCluster.scala:103)
>       at 
> org.apache.flink.runtime.minicluster.FlinkMiniCluster$$anonfun$1.apply(FlinkMiniCluster.scala:292)
>       at 
> org.apache.flink.runtime.minicluster.FlinkMiniCluster$$anonfun$1.apply(FlinkMiniCluster.scala:286)
>       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:286)
>       at 
> org.apache.flink.runtime.minicluster.FlinkMiniCluster.start(FlinkMiniCluster.scala:277)
>       at 
> org.apache.flink.test.util.ForkableFlinkMiniCluster.start(ForkableFlinkMiniCluster.scala:255)
>       at 
> org.apache.flink.test.util.TestBaseUtils.startCluster(TestBaseUtils.java:152)
>       at 
> org.apache.flink.test.util.TestBaseUtils.startCluster(TestBaseUtils.java:126)
>       at 
> org.flinkspector.datastream.DataStreamTestEnvironment.createTestEnvironment(DataStreamTestEnvironment.java:72)
> 
> Any ideas?
> 
> best,
> Stephan
> 
> 

Reply via email to