compile flink-gelly-scala using sbt

2015-10-27 Thread Le Quoc Do 
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

Re: compile flink-gelly-scala using sbt

2015-10-27 Thread Vasiliki Kalavri 
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  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
>

Re: compile flink-gelly-scala using sbt

2015-10-28 Thread Theodore Vasiloudis 
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  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  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
>>
>
>

Re: compile flink-gelly-scala using sbt

2015-10-28 Thread Le Quoc Do 
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  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
>>>
>>
>>
>

Re: compile flink-gelly-scala using sbt

2015-10-28 Thread Theodore Vasiloudis 
Could you share a minimal code example where this happens?

On Wed, Oct 28, 2015 at 4:22 PM, Le Quoc Do  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  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
>>>>
>>>
>>>
>>
>

Re: compile flink-gelly-scala using sbt

2015-10-28 Thread Le Quoc Do 
>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  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  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
>>>>>
>>>>
>>>>
>>>
>>
>

Re: compile flink-gelly-scala using sbt

2015-10-28 Thread Vasiliki Kalavri 
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  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: 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  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  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
>>>>>>
>>>>>
>>>>>
>>>>
>>>
>>
>