??????[ANNOUNCE] Welcome Matthias Sax as new committer

2015-09-02 Thread ????
Congratulations Matthias! :-) Cheers, Huang Wei -- About time ;) Welcome! > On 02 Sep 2015, at 08:13, Vasiliki Kalavri wrote: > > Congratulations Matthias! >> On Sep 2, 2015 5:42 AM, "Ufuk Celebi" wrote: >> >> Welcome Matthias! The Storm compatibility is a great addition

Re: [ANNOUNCE] Welcome Matthias Sax as new committer

2015-09-02 Thread Paris Carbone
About time ;) Welcome! > On 02 Sep 2015, at 08:13, Vasiliki Kalavri wrote: > > Congratulations Matthias! >> On Sep 2, 2015 5:42 AM, "Ufuk Celebi" wrote: >> >> Welcome Matthias! The Storm compatibility is a great addition to Flink :-) >> >> – Ufuk >> >> On Wed, Sep 2, 2015 at 5:24 PM, Márton

[jira] [Created] (FLINK-2610) run method in AbstractStormSpoutWrapper causes NPE

2015-09-02 Thread Boyang Jerry Peng (JIRA)
Boyang Jerry Peng created FLINK-2610: Summary: run method in AbstractStormSpoutWrapper causes NPE Key: FLINK-2610 URL: https://issues.apache.org/jira/browse/FLINK-2610 Project: Flink Issu

Re: [ANNOUNCE] Welcome Matthias Sax as new committer

2015-09-02 Thread Vasiliki Kalavri
Congratulations Matthias! On Sep 2, 2015 5:42 AM, "Ufuk Celebi" wrote: > Welcome Matthias! The Storm compatibility is a great addition to Flink :-) > > – Ufuk > > On Wed, Sep 2, 2015 at 5:24 PM, Márton Balassi > wrote: > > > Welcome, Matthias :) > > > > On Wed, Sep 2, 2015 at 5:21 PM, Aljoscha K

Re: How to force the parallelism on small streams?

2015-09-02 Thread Matthias J. Sax
Thanks for clarifying. shuffle() is similar to rebalance() -- however, it redistributes randomly and not in round robin fashion. However, the problem you describe sounds like a bug to me. I included dev list. Maybe anyone else can step in so we can identify it there is a bug or not. -Matthias O

Too many changed files building Flink web page

2015-09-02 Thread Matthias J. Sax
Hi, I just observed when building the Flink web page locally, that a lot of files got touched. Even files, that are not related to the actual change. After asking, it turned out that the problem is different versions of Jekyll that are used. I personally think that this is quite annoying and woul

To much changed file build Flink web page

2015-09-02 Thread Matthias J. Sax
Hi, I just observed when building the Flink web page locally, that a lot of files got touched. Even files, that are not related to the actual change. After asking, it turned out that the problem is different versions of Jekyll that are used. I personally think that this is quite annoying and woul

Re: [ANNOUNCE] Welcome Matthias Sax as new committer

2015-09-02 Thread Ufuk Celebi
Welcome Matthias! The Storm compatibility is a great addition to Flink :-) – Ufuk On Wed, Sep 2, 2015 at 5:24 PM, Márton Balassi wrote: > Welcome, Matthias :) > > On Wed, Sep 2, 2015 at 5:21 PM, Aljoscha Krettek > wrote: > > > Welcome, welcome, welcome :D > > > > On Wed, 2 Sep 2015 at 15:53 Fa

Re: [ANNOUNCE] Welcome Matthias Sax as new committer

2015-09-02 Thread Aljoscha Krettek
Welcome, welcome, welcome :D On Wed, 2 Sep 2015 at 15:53 Fabian Hueske wrote: > Welcome on board Matthias! > On Sep 2, 2015 15:40, "Maximilian Michels" wrote: > > > Well done, Matthias! Waiting for more exciting stuff to come. :) > > > > Cheers, > > Max > > > > On Wed, Sep 2, 2015 at 2:29 PM, S

Re: [ANNOUNCE] Welcome Matthias Sax as new committer

2015-09-02 Thread Márton Balassi
Welcome, Matthias :) On Wed, Sep 2, 2015 at 5:21 PM, Aljoscha Krettek wrote: > Welcome, welcome, welcome :D > > On Wed, 2 Sep 2015 at 15:53 Fabian Hueske wrote: > > > Welcome on board Matthias! > > On Sep 2, 2015 15:40, "Maximilian Michels" wrote: > > > > > Well done, Matthias! Waiting for mor

[jira] [Created] (FLINK-2609) Automatic type registration is only called from the batch execution environment

2015-09-02 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2609: - Summary: Automatic type registration is only called from the batch execution environment Key: FLINK-2609 URL: https://issues.apache.org/jira/browse/FLINK-2609 Proje

Re: [ANNOUNCE] Welcome Matthias Sax as new committer

2015-09-02 Thread Fabian Hueske
Welcome on board Matthias! On Sep 2, 2015 15:40, "Maximilian Michels" wrote: > Well done, Matthias! Waiting for more exciting stuff to come. :) > > Cheers, > Max > > On Wed, Sep 2, 2015 at 2:29 PM, Stephan Ewen wrote: > > > Welcome! > > > > On Wed, Sep 2, 2015 at 2:08 PM, Till Rohrmann > > wrot

Re: [ANNOUNCE] Welcome Matthias Sax as new committer

2015-09-02 Thread Maximilian Michels
Well done, Matthias! Waiting for more exciting stuff to come. :) Cheers, Max On Wed, Sep 2, 2015 at 2:29 PM, Stephan Ewen wrote: > Welcome! > > On Wed, Sep 2, 2015 at 2:08 PM, Till Rohrmann > wrote: > > > Congratulations Matthias! Welcome on board :-) > > > > On Wed, Sep 2, 2015 at 2:01 PM, Ro

Re: [ANNOUNCE] Welcome Matthias Sax as new committer

2015-09-02 Thread Stephan Ewen
Welcome! On Wed, Sep 2, 2015 at 2:08 PM, Till Rohrmann wrote: > Congratulations Matthias! Welcome on board :-) > > On Wed, Sep 2, 2015 at 2:01 PM, Robert Metzger > wrote: > > > Congrats Matthias! > > > > On Wed, Sep 2, 2015 at 1:34 PM, Timo Walther wrote: > > > > > Congratulations Matthias! >

Re: [ANNOUNCE] Welcome Matthias Sax as new committer

2015-09-02 Thread Till Rohrmann
Congratulations Matthias! Welcome on board :-) On Wed, Sep 2, 2015 at 2:01 PM, Robert Metzger wrote: > Congrats Matthias! > > On Wed, Sep 2, 2015 at 1:34 PM, Timo Walther wrote: > > > Congratulations Matthias! > > > > Regards, > > Timo > > > > > > On 02.09.2015 13:32, Chiwan Park wrote: > > > >

Re: [ANNOUNCE] Welcome Matthias Sax as new committer

2015-09-02 Thread Robert Metzger
Congrats Matthias! On Wed, Sep 2, 2015 at 1:34 PM, Timo Walther wrote: > Congratulations Matthias! > > Regards, > Timo > > > On 02.09.2015 13:32, Chiwan Park wrote: > >> Welcome Matthias! :) >> >> Regards, >> Chiwan Park >> >> On Sep 2, 2015, at 8:30 PM, Kostas Tzoumas wrote: >>> >>> The Projec

Re: [ANNOUNCE] Welcome Matthias Sax as new committer

2015-09-02 Thread Timo Walther
Congratulations Matthias! Regards, Timo On 02.09.2015 13:32, Chiwan Park wrote: Welcome Matthias! :) Regards, Chiwan Park On Sep 2, 2015, at 8:30 PM, Kostas Tzoumas wrote: The Project Management Committee (PMC) of Apache Flink has asked Matthias Sax to become a committer, and we are please

Re: [ANNOUNCE] Welcome Matthias Sax as new committer

2015-09-02 Thread Chiwan Park
Welcome Matthias! :) Regards, Chiwan Park > On Sep 2, 2015, at 8:30 PM, Kostas Tzoumas wrote: > > The Project Management Committee (PMC) of Apache Flink has asked Matthias > Sax to become a committer, and we are pleased to announce that he has > accepted. > > Matthias has been very active with

[ANNOUNCE] Welcome Matthias Sax as new committer

2015-09-02 Thread Kostas Tzoumas
The Project Management Committee (PMC) of Apache Flink has asked Matthias Sax to become a committer, and we are pleased to announce that he has accepted. Matthias has been very active with Flink, and he is the original contributor of the Storm compatibility functionality. Being a committer enable

[jira] [Created] (FLINK-2608) Arrays.asList(..) does not work with CollectionInputFormat

2015-09-02 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-2608: - Summary: Arrays.asList(..) does not work with CollectionInputFormat Key: FLINK-2608 URL: https://issues.apache.org/jira/browse/FLINK-2608 Project: Flink

[jira] [Created] (FLINK-2607) Shade plugin copies signature files from original jar into fat jar

2015-09-02 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-2607: - Summary: Shade plugin copies signature files from original jar into fat jar Key: FLINK-2607 URL: https://issues.apache.org/jira/browse/FLINK-2607 Project: F

Re: 答复: Some questions about storm metrics

2015-09-02 Thread Kostas Tzoumas
Sounds great. It is easy to create an AverageAccumulator by implementing the org.apache.flink.api.common.accumulators.Accumulator interface, accumulating the sum and the count internally, and dividing in the end. This would be something useful also outside of Storm compatibility. Then, MultiReduc

[jira] [Created] (FLINK-2606) Extend StormFileSpout to handle HDFS

2015-09-02 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created FLINK-2606: -- Summary: Extend StormFileSpout to handle HDFS Key: FLINK-2606 URL: https://issues.apache.org/jira/browse/FLINK-2606 Project: Flink Issue Type: New Featur