Hi,
I try to compile flink-gelly-scala using sbt. However, I got the following error: error] /home/ubuntu/git/flink-learning/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/Graph.scala:42: value getJavaEnv is not a member of org.apache.flink.api.scala.ExecutionEnvironment [error] wrapGraph(jg.Graph.fromDataSet[K, VV, EV](vertices.javaSet, edges.javaSet, env.getJavaEnv)) [error] ^ [error] /home/ubuntu/git/flink-learning/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/Graph.scala:51: value getJavaEnv is not a member of org.apache.flink.api.scala.ExecutionEnvironment [error] wrapGraph(jg.Graph.fromDataSet[K, EV](edges.javaSet, env.getJavaEnv)) The content of built.sbt file: name := "flink-graph-metrics" version := "1.0" scalaVersion := "2.11.6" libraryDependencies ++= Seq("org.apache.flink" % "flink-scala" % "0.9.1", "org.apache.flink" % "flink-clients" % "0.9.1", "org.apache.flink" % "flink-gelly" % "0.9.1") fork in run := true Do you know how to fix this problem? Thanks, Do ================================== Le Quoc Do Dresden University of Technology Faculty of Computer Science Institute for System Architecture Systems Engineering Group 01062 Dresden E-Mail: [hidden email] |
Hi Do, I don't really have experience with sbt, but one thing that might cause problems is that your dependencies point to Flink 0.9.1 and gelly-scala wasn't part of that release. You can either try to use the 0.10-SNAPSHOT or wait a few days for the 0.10 release. Cheers, -Vasia. On 27 October 2015 at 18:05, Le Quoc Do <[hidden email]> wrote:
|
Your build.sbt seems correct. In your code have you imported It might be that you are missing some basic imports.
On Tue, Oct 27, 2015 at 8:45 PM, Vasiliki Kalavri <[hidden email]> wrote:
|
Hi Theodore and Vasia,
Thanks for your reply. I can compile my code by add dependency jars manually. Yes, in my code, I already import Flink-scala (import org.apache.flink.api.scala._). However when I run my code, I get the following error: ava.lang.NoSuchMethodError: org.apache.flink.api.scala.ExecutionEnvironment.getJavaEnv()Lorg/apache/flink/api/java/ExecutionEnvironment;
at org.apache.flink.graph.scala.Graph$.fromDataSet(Graph.scala:53) any suggestions? Thanks, Do ================================== Le Quoc Do Dresden University of Technology Faculty of Computer Science Institute for System Architecture Systems Engineering Group 01062 Dresden E-Mail: [hidden email] On Wed, Oct 28, 2015 at 3:50 PM, Theodore Vasiloudis <[hidden email]> wrote:
|
Could you share a minimal code example where this happens? On Wed, Oct 28, 2015 at 4:22 PM, Le Quoc Do <[hidden email]> wrote:
|
From Graph.scala: def fromDataSet[K: TypeInformation : ClassTag, EV: TypeInformation : ClassTag] (edges: DataSet[Edge[K, EV]], env: ExecutionEnvironment): Graph[K, NullValue, EV] = { wrapGraph(jg.Graph.fromDataSet[K, EV](edges.javaSet, env.getJavaEnv)) } ================================== Le Quoc Do Dresden University of Technology Faculty of Computer Science Institute for System Architecture Systems Engineering Group 01062 Dresden E-Mail: [hidden email] On Wed, Oct 28, 2015 at 4:41 PM, Theodore Vasiloudis <[hidden email]> wrote:
|
Are you using 0.10-SNAPSHOT for this? Because in 0.9.1 this method (getJavaEnv()) indeed doesn't exist ;) On 28 October 2015 at 16:51, Le Quoc Do <[hidden email]> wrote:
|
Free forum by Nabble | Edit this page |