,
Simone.
On 03/04/2018 17:40, simone wrote:
I tried to run a simple batch job (it tooks about 5 minutes with flink
1.3.1 on single machine), but it seems to run forever with flink
1.5-SNAPSHOT (I stopped it after about 2-3 hours multiple times). If
you want to try to replicate this, here are the
Hi, below you can find my mail and my problem before the my subscribe to
mailing list.
simone
Da: simone sguazza
Inviato: lunedì 3 luglio 2017 11:57
A: dev@flink.apache.org
Oggetto: Problem to deploy of flink program in cluster
Hi, I'm a student and I
he execution of flink app with "sudo bin/flink run appFlink.jar".
You can see The flink application start and than do nothing more.
- the pom.xml
I think the problem is in the pom.xml but I don't know where.
Best regards, simone
http://maven.apache.org/POM/4.0.0"; xmlns:xsi=&
Overseer? Supervisor? Warden?
2016-05-31 21:23 GMT+02:00 Robert Metzger :
> Good point. I haven't thought about this name clash.
> However, I wonder whether it is clear from the context whether we are
> talking about pull request and component shepherding.
>
> Are there any other ideas for the
On this same subject, I have a question. Is it possible to achieve a lazy
count that transforms a DataSet[T] to a DataSet[Long] with a single value
containing the length of the original DataSet? Otherwise what is the best
way to count the elements lazily?
2016-05-30 23:49 GMT+02:00 Stephan Ewen :
I can't say for the second, but Deep NLP is an extremely specific niche and
it's out of scope for Flink to support such a functionality. Deep Learning
is not supported at all anyway. FlinkML, the machine learning library of
Flink, as many other ML libraries on distributed environments are focused
o
Ok, there is an OutOfMemory error apparently unrelated to the one reported
here that made the job fail.
2016-05-25 18:36 GMT+02:00 Simone Robutti :
> There were many errors after these (null pointers among them) so I assumed
> they were a consequence. If you say this shouldn't be
that actually fails the job. While it is true, these
> errors need to be solved, they should only be logged, never cause a
> failure.
>
> Stephan
>
>
> On Wed, May 25, 2016 at 3:49 PM, Maximilian Michels
> wrote:
>
> > Hi Simone,
> >
> > If you don't
;
> Stephan
>
>
> On Wed, May 25, 2016 at 2:22 PM, Simone Robutti <
> simone.robu...@radicalbit.io> wrote:
>
> > Running a job I encounter the following error that leads the job to
> failure
> > in the end.
> >
> > 14:09:34,722 ERROR org.a
Running a job I encounter the following error that leads the job to failure
in the end.
14:09:34,722 ERROR org.apache.flink.metrics.reporter.JMXReporter
- A metric with the name
org.apache.flink.metrics:key0=localhost,key1=taskmanager,key2=04a8fea67d01fbbdab5bba8c7e9a73d8,key3=Flink_Java_Job
I forgot to say that the version is 1.1-SNAPSHOT.
2016-05-25 14:22 GMT+02:00 Simone Robutti :
> Running a job I encounter the following error that leads the job to
> failure in the end.
>
> 14:09:34,722 ERROR org.apache.flink.metrics.reporter.JMXReporter
> - A metri
Simone Robutti created FLINK-3920:
-
Summary: Distributed Linear Algebra: block-based matrix
Key: FLINK-3920
URL: https://issues.apache.org/jira/browse/FLINK-3920
Project: Flink
Issue Type
Simone Robutti created FLINK-3919:
-
Summary: Distributed Linear Algebra: row-based matrix
Key: FLINK-3919
URL: https://issues.apache.org/jira/browse/FLINK-3919
Project: Flink
Issue Type: New
Thanks for the insight, what you're doing is really interesting. I will
definitely spend some time looking at DMLC and MXNet.
2016-03-12 18:35 GMT+01:00 Tianqi Chen :
> Thanks for the reply. I am writing a long email to give the answers to
> Simone and clarifies what we do
>
>
This is a really interesting approach. The idea of a ML library over
DataFlow is probably a winning move and I hope it will stop the
proliferation of worthless reimplementation that is taking place in the big
data world. Do you think that DataFlow posed specific problems to your
work? Does it missi
Simone Robutti created FLINK-3563:
-
Summary: .returns() doesn't compile when using .map() with a
custom MapFunction
Key: FLINK-3563
URL: https://issues.apache.org/jira/browse/FLINK-3563
Pr
re to enquire about the interest by others to work on this
project and if anyone else began working on it.
I will engage the H2O community on this subject later today to probe their
sentiment on this possibility and ask for technical advices.
Best regards,
Simone
would be great if FlinkML had something like
> it.
>
> There was a good audience to Sebastian's talk on this subject at #FF15 in
> October.
>
> 5. Its a good idea to add Flink support to H2O as Slim had suggested
> elsewhere in this thread.
>
>
> Thoughts?
>
>
>
Asking as someone that never did NN on Flink, would you implement it using
JCuda? And would you implement it with model parallelization? Is there any
theoretical limit to implement "model and data parallelism" in Flink? If
you don't use GPUs and you don't parallelize models and data at the same
tim
resting opinion. Also I had no historical visibility on the motivations
and discussions behind the development of FlinkML and I would like pointers
to read something on what is the shared vision on this part of the project
so that I could join the discussion from now on.
Thanks,
Simone
2016-
Simone Robutti created FLINK-3191:
-
Summary: WordCount without fileOutput - execute is missing
Key: FLINK-3191
URL: https://issues.apache.org/jira/browse/FLINK-3191
Project: Flink
Issue Type
22 matches
Mail list logo
