Re: Flink's Checking and uploading JAR files Issue

2015-09-24 Thread Hanan Meyer
ava:70) at com.scalabill.it.pa.core.FlinkDriver.generateChannelsCSVsforThisBackendServer(FlinkDriver.java:94) Have I been doing the walk-around currently ? Can you try to reproduce it in your environment ? Thanks for your attention! Hanan Meyer On Thu, Sep 24, 2015 at 4:58 PM, Till Rohrmann <till.rohrm...@gmail.com> wrote: > Hi Hanan, > > you're right that

Flink ML linear regression issue

2015-09-17 Thread Hanan Meyer
to pass the train dataset to it as a parameter or by setter. I'll be more than happy if you could guide me how to implement it in Java Thanks Hanan Meyer

Re: Flink ML source code

2015-09-11 Thread Hanan Meyer
pache/flink/tree/master/flink-staging/flink-ml > > > > On Thu, Sep 10, 2015 at 4:12 PM, Hanan Meyer <ha...@scalabill.it> wrote: > > > > > Hi > > > > > > I would like to implement an Anova algorithm based on Flink's ML > library. > &

Flink ML source code

2015-09-10 Thread Hanan Meyer
Hi I would like to implement an Anova algorithm based on Flink's ML library. Unfortunately I can't find the Flink 0.10 source code . Is there a any way to get the code ? In case that I'll manage to implement my idea I'll share it with the community of course ... Thanks , Hanan Meyer

Re: Apache Flink:ProgramInvocationException on Yarn

2015-08-30 Thread Hanan Meyer
hostname (or ip). Can you pass the correct hostname when you call ExecutionEnvironment. createRemoteEnvironment(). On Fri, Aug 28, 2015 at 7:52 AM, Hanan Meyer ha...@scalabill.it wrote: Hi I'm currently using flink 0.9.0 which by maven support Hadoop 1 . By using flink-clients-0.7.0-hadoop2

Re: Apache Flink:ProgramInvocationException on Yarn

2015-08-30 Thread Hanan Meyer
to be randomized. It may be worth adding a YARNExecutionEnvironment at some point, which deals with this transparent (starting the YARN cluster, connecting to the JobManager). On Sun, Aug 30, 2015 at 10:12 AM, Hanan Meyer ha...@scalabill.it wrote: Hello. Let me clarify

Re: Apache Flink:ProgramInvocationException on Yarn

2015-08-28 Thread Hanan Meyer
Hi I'm running with a formal server ip but for securuty reasons I can't share with you the real ip . I put FLINK_SERVER_URL in order to replace the actual ip only in my post . Hanan Meyer On Fri, Aug 28, 2015 at 10:27 AM, Robert Metzger rmetz...@apache.org wrote: Hi, in the exception you've

Re: Apache Flink:ProgramInvocationException on Yarn

2015-08-27 Thread Hanan Meyer
Hi I'm currently using flink 0.9.0 which by maven support Hadoop 1 . By using flink-clients-0.7.0-hadoop2-incubating.jar with executePlan(Plan p) method instead, I'm getting the same exception Hanan On Fri, Aug 28, 2015 at 8:35 AM, Hanan Meyer ha...@scalabill.it wrote: Hi 1. I have

Re: Apache Flink:ProgramInvocationException on Yarn

2015-08-27 Thread Hanan Meyer
you deploy Flink on YARN, the host and port change, because the JobManager is started on a different YARN container. On Thu, Aug 27, 2015 at 6:32 PM, Hanan Meyer ha...@scalabill.it wrote: Hello All When using Eclipse IDE to submit Flink to Yarn single node cluster I'm