Re: Flink's Checking and uploading JAR files Issue

Hi I rechecked that I put all my Jars in the Lib folder . I have also noticed that it fails while loading my first Pojo class . I start the cluster via Yarn using Flink 0.9.1 . Thanks , Mr Hanan Meyer On Thu, Sep 24, 2015 at 6:08 PM, Stephan Ewen wrote: > My first guess would be that

Re: Flink's Checking and uploading JAR files Issue

sv(FlinkCSVProducer.java: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 wrote: > Hi Hanan, > > you're right that

Flink's Checking and uploading JAR files Issue

Flink from a J2EE Aplication Server . The Jars serialization and transportation takes a huge part of the execution time . Is there a way to force Flink to pass the Jars only once? Please advise Thanks, Hanan Meyer

Flink ML linear regression issue

found a way 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

t me know. I'd like to > assist you. > > Cheers, > Till > > On Thu, Sep 10, 2015 at 4:15 PM, Robert Metzger > wrote: > > > Hi, > > > > you can find the Flink ML source code here: > > https://github.com/apache/flink/tree/master/flink-stag

Flink ML source code

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

t is usually not 6123. Yarn starts many services on one machine, so > the > > ports need 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 > >

Re: Apache Flink:ProgramInvocationException on Yarn

is: "akka.tcp://flink@1.2.3.4:6123/". So it seems that you are > passing FLINK_SERVER_URL > as the server 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 w

Re: Apache Flink:ProgramInvocationException on Yarn

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 wrote: > Hi, > > i

Re: Apache Flink:ProgramInvocationException on Yarn

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 wrote: > > Hi > > 1.

Re: Apache Flink:ProgramInvocationException on Yarn

n Thu, Aug 27, 2015 at 6:39 PM, Robert Metzger > > > wrote: > > > > > >> Hi, > > >> > > >> Which values did you use for FLINK_SERVER_URL and FLINK_PORT? > > >> Every time you deploy Flink on YARN, the host and port change, because

Apache Flink:ProgramInvocationException on Yarn

_PATH_ON_CLIENT); DataSet data = envRemote.readTextFile("hdfs://localhost:9000/flink/in.txt"); data.writeAsText("hdfs://localhost:9000/flink/out.txt"); envRemote.execute(); Please advise, Hanan Meyer