Re: Towards Flink 0.10

2015-10-06 Thread Alexey Sapozhnikov
> > > > the > > > > > > > > last release before 1.0. > > > > > > > > > > > > > > > > For 0.10 we most noticeably have the new Streaming API which > > > comes > > > > > > > > with an improved runtime including exactly-once sources and > > > sinks. > > > > > > > > Additionally, we have a new web interface with support for > > > > > > > > live-monitoring. Not to mention the countless fixes and > > > > improvements. > > > > > > > > > > > > > > > > I've been ransacking the JIRA issues to find out what issues > we > > > > have > > > > > > > > to fix before we can release. I've put these issues on the > 0.10 > > > > wiki > > > > > > > > page: > > > > https://cwiki.apache.org/confluence/display/FLINK/0.10+Release > > > > > > > > > > > > > > > > It would be great to fix all of these issues. However, I > think > > we > > > > > need > > > > > > > > to be pragmatic and pick the most pressing ones. Let's do > that > > on > > > > the > > > > > > > > wiki page on the "To Be Fixed" section. > > > > > > > > > > > > > > > > Cheers, > > > > > > > > Max > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > -- *Regards* *Alexey Sapozhnikov* CTO& Co-Founder Scalabillit Inc Aba Even 10-C, Herzelia, Israel M : +972-52-2363823 E : ale...@scalabill.it W : http://www.scalabill.it YT - https://youtu.be/9Rj309PTOFA Map:http://mapta.gs/Scalabillit Revolutionizing Proof-of-Concept

Re: Flink ML linear regression issue

2015-09-17 Thread Alexey Sapozhnikov
ve been > already > implemented in Flinks ml source code. > > Another option is using MultipleLinearRegression.fitMLR() method ,but I > haven't 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 imple

Re: Apache Flink:ProgramInvocationException on Yarn

2015-08-30 Thread Alexey Sapozhnikov
wrote: > Why are the external IPs not working? Any kind of exception you can share? > > On Sun, Aug 30, 2015 at 5:02 PM, Alexey Sapozhnikov > wrote: > > > it will not help, since the internal IPs are changing in AWS from time to > > time and you should use only Public IP, w

Re: Apache Flink:ProgramInvocationException on Yarn

2015-08-30 Thread Alexey Sapozhnikov
> > On Sun, Aug 30, 2015 at 4:44 PM, Alexey Sapozhnikov > wrote: > > > Fully understand. > > 1.My suggestion is to drop Akka and take something else, since this issue > > is really big > > 2.Not hostname not the endpoint are not working, clarifying the VPC topi

Re: Apache Flink:ProgramInvocationException on Yarn

2015-08-30 Thread Alexey Sapozhnikov
side, we have been using Flink on Cloud Platforms GCE, Amazon, > and it worked. > > Can you try to use the internal hostname, or the fully qualified external > hostname? > > > On Sun, Aug 30, 2015 at 4:23 PM, Alexey Sapozhnikov > wrote: > > > Hi. > > First off

Re: Apache Flink:ProgramInvocationException on Yarn

2015-08-30 Thread Alexey Sapozhnikov
mazon-Linux.html > Can you easily activate a DNS server in the VPC? > > 0.0.0.0 is not supported because of some requirements of the Akka > framework. > But you should be able to use the host's IP address. > Can you try that as well? > > > > > On Sun, Aug 30, 2015

Re: Apache Flink:ProgramInvocationException on Yarn

2015-08-30 Thread Alexey Sapozhnikov
ger.getJobManagerRemoteReference(JobManager.scala) > > > > > > > > > > at > > > org.apache.flink.client.program.Client.run(Client.java:376) > > > > > > > > > > ... 7 more > > > > > > > > > > Caused by: a

Re: Apache Flink:ProgramInvocationException on Yarn

2015-08-30 Thread Alexey Sapozhnikov
; > Batch$$anonfun$run$1.processBatch$1(BatchingExecutor.scala:67) > > > > > > > > at > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > akka.dispatch.Batch

Re: Apache Flink:ProgramInvocationException on Yarn

2015-08-27 Thread Alexey Sapozhnikov
Hello all. Some clarification: locally everything works great. However once we run our Flink on remote linux machine and try to run the client program from our machine, using create remote environment- Flink JobManager is raising this exception On Thu, Aug 27, 2015 at 7:41 PM, Stephan Ewen wrote

Re: Apache Flink:ProgramInvocationException on Yarn

2015-08-27 Thread Alexey Sapozhnikov
Hello all. Some clarification: locally everything works great. However once we run our Flink on remote linux machine and try to run the client program from our machine, using create remote environment- Flink JobManager is raising this exception On Thu, Aug 27, 2015 at 7:41 PM, Stephan Ewen wrote