>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
>>>>>
>>>>
>>>>
>>>
>>
>

Reply via email to