flink-git - an experiment in exactly-once semantics

Hello, On a long plane trip I had some fun with writing a Flink streaming connector based on Git. https://github.com/EronWright/flink-git Not intended for real application use; flink-git is just an experiment meant for discussion. Flink's Kafka connector provides exactly-once guarantees when ac

[jira] [Created] (FLINK-3806) Revert use of DataSet.count() in Gelly

Greg Hogan created FLINK-3806: - Summary: Revert use of DataSet.count() in Gelly Key: FLINK-3806 URL: https://issues.apache.org/jira/browse/FLINK-3806 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3805) BloomFilter initialized with no memory available

Greg Hogan created FLINK-3805: - Summary: BloomFilter initialized with no memory available Key: FLINK-3805 URL: https://issues.apache.org/jira/browse/FLINK-3805 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3804) Update YARN documentation

Till Rohrmann created FLINK-3804: Summary: Update YARN documentation Key: FLINK-3804 URL: https://issues.apache.org/jira/browse/FLINK-3804 Project: Flink Issue Type: Improvement Com

Re: [VOTE] Release Apache Flink 1.0.2 (RC3)

Thanks. I realized that just after posting and corrected it already in the new thread. Didn't want to post to this thread again. Now look how that went :) On Fri, Apr 22, 2016 at 11:15 AM, Aljoscha Krettek wrote: > @Max, this issue is only relevant for 1.1.x AFAIK. The 1.0.x series does > not hav

[jira] [Created] (FLINK-3803) Checkpoint Stats Tracker Reads from Wrong Configuration

Aljoscha Krettek created FLINK-3803: --- Summary: Checkpoint Stats Tracker Reads from Wrong Configuration Key: FLINK-3803 URL: https://issues.apache.org/jira/browse/FLINK-3803 Project: Flink I

Re: [DISCUSS] Release Flink 1.0.3

https://issues.apache.org/jira/browse/FLINK-3701 does not affect the 1.0.x series of releases, I think we also discussed this in the 1.0.2 release thread. On Fri, 22 Apr 2016 at 10:39 Kostas Kloudas wrote: > I am working on: > https://issues.apache.org/jira/browse/FLINK-2314?filter=-1 < > https:

Re: [VOTE] Release Apache Flink 1.0.2 (RC3)

@Max, this issue is only relevant for 1.1.x AFAIK. The 1.0.x series does not have that bug. On Fri, 22 Apr 2016 at 10:21 Maximilian Michels wrote: > +1 also from my side for releasing the RC as 1.0.2. We'll collect new > issues in the thread Robert opened. > > On Thu, Apr 21, 2016 at 7:04 PM, Ro

Re: [DISCUSS] Graph algorithms for vertex and edge degree

Hi all, I asked Greg to start a discussion here about FLINK-3771 and FLINK-3772, to make sure we're all on the same page about future Gelly development. About a year ago we created the Gelly roadmap [1]. Many of these items have been implemented and others were researched and either developed ext

Re: [DISCUSS] Release Flink 1.0.3

I am working on: https://issues.apache.org/jira/browse/FLINK-2314?filter=-1 which I believe will also affect: https://issues.apache.org/jira/browse/FLINK-3796 Essentially the FileSourceFunction will become obsolete. > On Apr 22, 2016

Re: [DISCUSS] Release Flink 1.0.3

Hi Robert, Thanks for starting a new thread for Flink 1.0.3. FLINK-3701 can be removed. It's only affects the upcoming 1.1.0 release. I would like to add https://issues.apache.org/jira/browse/FLINK-3796 Cheers, Max On Thu, Apr 21, 2016 at 7:04 PM, Robert Metzger wrote: > Hi, > > in the 1.0.2 r

Re: [VOTE] Release Apache Flink 1.0.2 (RC3)

+1 also from my side for releasing the RC as 1.0.2. We'll collect new issues in the thread Robert opened. On Thu, Apr 21, 2016 at 7:04 PM, Robert Metzger wrote: > I started a new thread for the 1.0.3 release to collect all the JIRAs there. > > On Thu, Apr 21, 2016 at 6:52 PM, Maximilian Michels