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

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

Re: 答复: Some questions about storm metrics

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,

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

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

Too many changed files building Flink web page

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

Re: [ANNOUNCE] Welcome Matthias Sax as new committer

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 > >

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

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

Re: [ANNOUNCE] Welcome Matthias Sax as new committer

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

[ANNOUNCE] Welcome Matthias Sax as new committer

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

Re: [ANNOUNCE] Welcome Matthias Sax as new committer

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

Re: [ANNOUNCE] Welcome Matthias Sax as new committer

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

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

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

Re: [ANNOUNCE] Welcome Matthias Sax as new committer

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

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

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: