On 03 Jan 2017, at 22:06, Stephan Ewen <[hidden email]> wrote:Hi!It is probably some inconsistent configuration in the IDE.It often helps to do "Maven->Reimport" or use "restart and clear caches".On Tue, Jan 3, 2017 at 9:48 AM, Stephan Epping <[hidden email]> wrote: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 <[hidden email]> wrote:Seems like you didn't setup the correct scala SDKbest,KurtOn Mon, Jan 2, 2017 at 10:41 PM, Stephan Epping <[hidden email]> 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$.startJobMana gerActors(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.startJob Manager(ForkableFlinkMiniClust er.scala:103) at org.apache.flink.runtime.minicluster.FlinkMiniCluster$$anonf un$1.apply(FlinkMiniCluster. scala:292) at org.apache.flink.runtime.minicluster.FlinkMiniCluster$$anonf un$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(Fo rkableFlinkMiniCluster.scala: 255) at org.apache.flink.test.util.TestBaseUtils.startCluster(TestBa seUtils.java:152) at org.apache.flink.test.util.TestBaseUtils.startCluster(TestBa seUtils.java:126) at org.flinkspector.datastream.DataStreamTestEnvironment.create TestEnvironment(DataStreamTest Environment.java:72) Any ideas?best,Stephan
Free forum by Nabble | Edit this page |