l execute your program up until that point. The Csv writes are
> after this point, so in order to execute these steps I think you would have
> to call .execute() after the Csv writes to trigger the execution (where
> is the name of the variable pointing to your ExecutionEnvironment).
>
Hi,
I need some help to figure out why one method of mine in a pipeline stops the
execution on the hdfs.
I am working with the 10.0-SNAPSHOT and the code is the following (see below).
The method stops on the hdfs by calling the collect method
(JoinPredictionAndOriginal.collect) creating a data s
schrieb Stephan Ewen :
> Hi!
>
> Looks like you submitted the program JAR, but it did not contain all required
> libraries, like the breeze JAR.
>
> Did you build a proper fat jar, or how did you package the program?
>
> Greetings,
> Stephan
>
> On Fri, Sep
Hey Guys need your help again,
I am currently having problems with the multiple linear regression from the
flink-ml on the HDFS.
Locally it works fine with the 0.9-SNAPSHOT. The cluster runs with the
0.10-SNAPSHOT. The code is the following:
// set linear regression with parameters:
val mlr = Mu
There is a bug in the web client which sets the wrong class loader when
> running the user code.
>
> On Tue, Sep 8, 2015 at 12:05 PM, Florian Heyl wrote:
> Locally we are using the 0.9-SNAPSHOT but the cluster should work with the
> 0.10-SNAPSHOT. I have no direct control of
12:48 schrieb Robert Metzger :
> Which version of Flink are you using?
>
> Have you tried submitting the job using the "./bin/flink run" tool?
>
> On Tue, Sep 8, 2015 at 11:44 AM, Florian Heyl wrote:
> Dear Sir or Madam,
> Me and my colleague are developing a pipe
Dear Sir or Madam,
Me and my colleague are developing a pipeline based on scala and java to
classify cancer stages. This pipeline should be uploaded on the hdfs (apache
flink).
The pipeline locally works fine but on the hdfs it crashes with the following
error (see below). The main method is sim
