Re: [ANNOUNCE] Welcome Stefan Richter as a new committer

Congrats! On Fri, Feb 10, 2017 at 9:11 PM, Matthias J. Sax wrote: > -BEGIN PGP SIGNED MESSAGE- > Hash: SHA512 > > Congrats! > > On 2/10/17 2:00 AM, Ufuk Celebi wrote: > > Hey everyone, > > > > I'm very happy to announce that the Flink PMC has accepted Stefan > > Richter to become a commi

Flink ML - NaN Handling

Hello guys, Is there a story for this (might have been discussed earlier)? I see differences between scikit-learn and numpy. Do we standardize on scikit-learn? PS. I am working on the preprocessing stuff. Best, Stavros

[jira] [Created] (FLINK-5783) flink-connector-kinesis java.lang.NoClassDefFoundError: org/apache/http/conn/ssl/SSLSocketFactory

Huy Huynh created FLINK-5783: Summary: flink-connector-kinesis java.lang.NoClassDefFoundError: org/apache/http/conn/ssl/SSLSocketFactory Key: FLINK-5783 URL: https://issues.apache.org/jira/browse/FLINK-5783

Re: [ANNOUNCE] Welcome Stefan Richter as a new committer

-BEGIN PGP SIGNED MESSAGE- Hash: SHA512 Congrats! On 2/10/17 2:00 AM, Ufuk Celebi wrote: > Hey everyone, > > I'm very happy to announce that the Flink PMC has accepted Stefan > Richter to become a committer of the Apache Flink project. > > Stefan is part of the community for almost a y

Re: [ANNOUNCE] Welcome Stefan Richter as a new committer

Congratz Stefan! Keep up with the neat contributions > On 10 Feb 2017, at 17:10, Haohui Mai wrote: > > Congrats! > On Fri, Feb 10, 2017 at 8:08 AM Henry Saputra > wrote: > >> Congrats and welcome! >> >> On Fri, Feb 10, 2017 at 7:45 AM, Tzu-Li (Gordon) Tai >> wrote: >> >>> Great news! Welcom

Re: New Flink team member - Kate Eri.

I have created the ticket to discuss GPU related questions futher https://issues.apache.org/jira/browse/FLINK-5782 пт, 10 февр. 2017 г. в 18:16, Katherin Eri : > Thank you, Trevor! > > You have shared very valuable points; I will consider them. > > So I think, I should create finally ticket at Fl

[jira] [Created] (FLINK-5782) Support GPU calculations

Kate Eri created FLINK-5782: --- Summary: Support GPU calculations Key: FLINK-5782 URL: https://issues.apache.org/jira/browse/FLINK-5782 Project: Flink Issue Type: Improvement Components: Co

[jira] [Created] (FLINK-5781) Generation HTML from ConfigOption

Ufuk Celebi created FLINK-5781: -- Summary: Generation HTML from ConfigOption Key: FLINK-5781 URL: https://issues.apache.org/jira/browse/FLINK-5781 Project: Flink Issue Type: Sub-task Co

[jira] [Created] (FLINK-5780) Extend ConfigOption with descriptions

Ufuk Celebi created FLINK-5780: -- Summary: Extend ConfigOption with descriptions Key: FLINK-5780 URL: https://issues.apache.org/jira/browse/FLINK-5780 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-5779) Auto generate configuration docs

Ufuk Celebi created FLINK-5779: -- Summary: Auto generate configuration docs Key: FLINK-5779 URL: https://issues.apache.org/jira/browse/FLINK-5779 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5778) Split FileStateHandle into fileName and basePath

Ufuk Celebi created FLINK-5778: -- Summary: Split FileStateHandle into fileName and basePath Key: FLINK-5778 URL: https://issues.apache.org/jira/browse/FLINK-5778 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-5777) Pass savepoint information to CheckpointingOperation

Ufuk Celebi created FLINK-5777: -- Summary: Pass savepoint information to CheckpointingOperation Key: FLINK-5777 URL: https://issues.apache.org/jira/browse/FLINK-5777 Project: Flink Issue Type: Su

Re: [ANNOUNCE] Welcome Stefan Richter as a new committer

Congrats! On Fri, Feb 10, 2017 at 8:08 AM Henry Saputra wrote: > Congrats and welcome! > > On Fri, Feb 10, 2017 at 7:45 AM, Tzu-Li (Gordon) Tai > wrote: > > > Great news! Welcome Stefan :-D > > > > > > On February 10, 2017 at 11:36:14 PM, Aljoscha Krettek ( > aljos...@apache.org) > > wrote: > >

Re: [ANNOUNCE] Welcome Stefan Richter as a new committer

Congrats and welcome! On Fri, Feb 10, 2017 at 7:45 AM, Tzu-Li (Gordon) Tai wrote: > Great news! Welcome Stefan :-D > > > On February 10, 2017 at 11:36:14 PM, Aljoscha Krettek (aljos...@apache.org) > wrote: > > Welcome! :-) > > On Fri, 10 Feb 2017 at 16:10 Till Rohrmann wrote: > > > Great to hav

Re: [ANNOUNCE] Welcome Jark Wu and Kostas Kloudas as committers

Awesome! Congrats and Welcome, Jark and Kostas K. - Henry On Tue, Feb 7, 2017 at 12:16 PM, Fabian Hueske wrote: > Hi everybody, > > I'm very happy to announce that Jark Wu and Kostas Kloudas accepted the > invitation of the Flink PMC to become committers of the Apache Flink > project. > > Jark

Re: [ANNOUNCE] Welcome Stefan Richter as a new committer

Great news! Welcome Stefan :-D On February 10, 2017 at 11:36:14 PM, Aljoscha Krettek (aljos...@apache.org) wrote: Welcome! :-) On Fri, 10 Feb 2017 at 16:10 Till Rohrmann wrote: > Great to have you on board as a committer Stefan :-) > > On Fri, Feb 10, 2017 at 3:32 PM, Greg Hogan wro

Re: [ANNOUNCE] Welcome Stefan Richter as a new committer

Welcome! :-) On Fri, 10 Feb 2017 at 16:10 Till Rohrmann wrote: > Great to have you on board as a committer Stefan :-) > > On Fri, Feb 10, 2017 at 3:32 PM, Greg Hogan wrote: > > > Welcome, Stefan, and thank you for your contributions! > > > > On Fri, Feb 10, 2017 at 5:00 AM, Ufuk Celebi wrote:

Re: New Flink team member - Kate Eri.

Thank you, Trevor! You have shared very valuable points; I will consider them. So I think, I should create finally ticket at Flink’s JIRA, at least for Flink's GPU support and move the related discussion there? I will contact to Suneel regarding DL4J, thanks! пт, 10 февр. 2017 г. в 17:44, Trev

[jira] [Created] (FLINK-5776) Improve XXMapRunner support create instance by carrying constructor parameters

sunjincheng created FLINK-5776: -- Summary: Improve XXMapRunner support create instance by carrying constructor parameters Key: FLINK-5776 URL: https://issues.apache.org/jira/browse/FLINK-5776 Project: Fli

Re: [ANNOUNCE] Welcome Stefan Richter as a new committer

Great to have you on board as a committer Stefan :-) On Fri, Feb 10, 2017 at 3:32 PM, Greg Hogan wrote: > Welcome, Stefan, and thank you for your contributions! > > On Fri, Feb 10, 2017 at 5:00 AM, Ufuk Celebi wrote: > > > Hey everyone, > > > > I'm very happy to announce that the Flink PMC has

Re: [ANNOUNCE] Welcome Jark Wu and Kostas Kloudas as committers

Congrats! :-) On Wed, 8 Feb 2017 at 11:29 Robert Metzger wrote: > Welcome on board guys! > > If you want to try our your new privileges, you can add yourself here: > http://flink.apache.org/community.html#people (through the > apache/flink-web > repo) > > On Wed, Feb 8, 2017 at 10:52 AM, Till Ro

Using QueryableState inside Flink jobs (and Parameter Server implementation)

Hi all, TL;DR: Is it worth to implement a special QueryableState for querying state from another part of a Flink streaming job and aligning it with fault tolerance? I've been thinking about implementing a Parameter Server with/within Flink. A Parameter Server is basically a specialized key-v

Re: New Flink team member - Kate Eri.

Also RE: DL4J integration. Suneel had done some work on this a while back, and ran into issues. You might want to chat with him about the pitfalls and 'gotchyas' there. Trevor Grant Data Scientist https://github.com/rawkintrevo http://stackexchange.com/users/3002022/rawkintrevo http://trevorgr

[jira] [Created] (FLINK-5775) NullReferenceException when running job on local cluster

Colin Breame created FLINK-5775: --- Summary: NullReferenceException when running job on local cluster Key: FLINK-5775 URL: https://issues.apache.org/jira/browse/FLINK-5775 Project: Flink Issue Ty

Re: [ANNOUNCE] Welcome Stefan Richter as a new committer

Welcome, Stefan, and thank you for your contributions! On Fri, Feb 10, 2017 at 5:00 AM, Ufuk Celebi wrote: > Hey everyone, > > I'm very happy to announce that the Flink PMC has accepted Stefan > Richter to become a committer of the Apache Flink project. > > Stefan is part of the community for al

回复：[ANNOUNCE] Welcome Stefan Richter as a new committer

Congrats Stefan! --发件人：Ufuk Celebi日　期：2017年02月10日 18:00:09收件人：; 抄　送：主　题：[ANNOUNCE] Welcome Stefan Richter as a new committerHey everyone, I'm very happy to announce that the Flink PMC has accepted Stefan Richter to become a comm

[jira] [Created] (FLINK-5774) ContinuousFileProcessingTest has test instability

Aljoscha Krettek created FLINK-5774: --- Summary: ContinuousFileProcessingTest has test instability Key: FLINK-5774 URL: https://issues.apache.org/jira/browse/FLINK-5774 Project: Flink Issue T

Re: New Flink team member - Kate Eri.

Sorry for chiming in late. GPUs on Flink. Till raised a good point- you need to be able to fall back to non-GPU resources if they aren't available. Fun fact: this has already been developed for Flink vis-a-vis the Apache Mahout project. In short- Mahout exposes a number of tensor functions (vec

Re: New Flink team member - Kate Eri.

Thank you Felix, for provided information. Currently I analyze the provided integration of Flink with SystemML. And also gather the information for the ticket FLINK-1730 , maybe we will take it to work, to unlock SystemML/Flink integration. чт

[jira] [Created] (FLINK-5773) Cannot cast scala.util.Failure to org.apache.flink.runtime.messages.Acknowledge

Colin Breame created FLINK-5773: --- Summary: Cannot cast scala.util.Failure to org.apache.flink.runtime.messages.Acknowledge Key: FLINK-5773 URL: https://issues.apache.org/jira/browse/FLINK-5773 Project:

[jira] [Created] (FLINK-5772) Instability with embedded Elasticsearch node in ElasticsearchSink test

Tzu-Li (Gordon) Tai created FLINK-5772: -- Summary: Instability with embedded Elasticsearch node in ElasticsearchSink test Key: FLINK-5772 URL: https://issues.apache.org/jira/browse/FLINK-5772 Proj

[ANNOUNCE] Welcome Stefan Richter as a new committer

Hey everyone, I'm very happy to announce that the Flink PMC has accepted Stefan Richter to become a committer of the Apache Flink project. Stefan is part of the community for almost a year now and worked on major features of the latest 1.2 release, most notably rescaling and backwards compatibili

[jira] [Created] (FLINK-5771) DelimitedInputFormat does not correctly handle muli-byte delimiters

Colin Breame created FLINK-5771: --- Summary: DelimitedInputFormat does not correctly handle muli-byte delimiters Key: FLINK-5771 URL: https://issues.apache.org/jira/browse/FLINK-5771 Project: Flink

Running multiple streaming jobs in same cluster

Hi everyone, We have a huge execution graph for one streaming job. To update this execution graph, we take the snapshot of the job and start the job with snapshot. However this can take too much time. One option is splitting this huge streaming job into smaller ones. We can cancel or run new