>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: d...@se.inf.tu-dresden.de On Wed, Oct 28, 2015 at 4:41 PM, Theodore Vasiloudis < theodoros.vasilou...@gmail.com> wrote: > Could you share a minimal code example where this happens? > > On Wed, Oct 28, 2015 at 4:22 PM, Le Quoc Do <lequo...@gmail.com> 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: d...@se.inf.tu-dresden.de >> >> On Wed, Oct 28, 2015 at 3:50 PM, Theodore Vasiloudis < >> theodoros.vasilou...@gmail.com> wrote: >> >>> Your build.sbt seems correct. >>> It might be that you are missing some basic imports. >>> >>> In your code have you imported >>> >>> import org.apache.flink.api.scala._ >>> >>> ? >>> >>> >>> On Tue, Oct 27, 2015 at 8:45 PM, Vasiliki Kalavri < >>> vasilikikala...@gmail.com> wrote: >>> >>>> 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 <lequo...@gmail.com> wrote: >>>> >>>>> 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: d...@se.inf.tu-dresden.de >>>>> >>>> >>>> >>> >> >