Guide for Flink Source/Sinks

Hi Folks: I am new to Flink and wanted to find out if there is a guide to how to create new sources/sinks for Flink. I tried browsing through the documentation but did not find a single place with all the interfaces/etc required. Thanks for your help. Mans

Service frontend as a source and sink

I'm looking into integrating AWS Flow Framework with Flink. One of the requirements is to provide a service API to initiate workflows and query their state. I envision that this API could be integrated as a specialized source that takes web requests and a

[jira] [Created] (FLINK-3888) Custom Aggregator with Convergence can't be registered directly with DeltaIteration

Martin Liesenberg created FLINK-3888: Summary: Custom Aggregator with Convergence can't be registered directly with DeltaIteration Key: FLINK-3888 URL: https://issues.apache.org/jira/browse/FLINK-3888

Re: Janino related question

Hi, Thank you for your support, I was able to solve this issue :) Gábor On 9 May 2016 at 12:15, Aljoscha Krettek wrote: > Hi Gábor, > I used it, yes, but I never encountered such a problem. Let's hope that the > error message Márton discovered helps. :-) > > Cheers, > Aljoscha > > On Mon, 9 Ma

[jira] [Created] (FLINK-3887) Improve dependency management for building docs

Maximilian Michels created FLINK-3887: - Summary: Improve dependency management for building docs Key: FLINK-3887 URL: https://issues.apache.org/jira/browse/FLINK-3887 Project: Flink Issue

[jira] [Created] (FLINK-3886) Give a better error when the application Main class is not public.

Niels Basjes created FLINK-3886: --- Summary: Give a better error when the application Main class is not public. Key: FLINK-3886 URL: https://issues.apache.org/jira/browse/FLINK-3886 Project: Flink

[jira] [Created] (FLINK-3885) Revisit parallelism logic

Till Rohrmann created FLINK-3885: Summary: Revisit parallelism logic Key: FLINK-3885 URL: https://issues.apache.org/jira/browse/FLINK-3885 Project: Flink Issue Type: Bug Components:

Re: Janino related question

Hi Gábor, I used it, yes, but I never encountered such a problem. Let's hope that the error message Márton discovered helps. :-) Cheers, Aljoscha On Mon, 9 May 2016 at 11:38 Márton Balassi wrote: > Hi Gabor, > > I have checked out your branch and tried debugging WordCountPojo to > reproduce the

[jira] [Created] (FLINK-3884) Snapshot quickstart projects don't include snapshot repository

Ufuk Celebi created FLINK-3884: -- Summary: Snapshot quickstart projects don't include snapshot repository Key: FLINK-3884 URL: https://issues.apache.org/jira/browse/FLINK-3884 Project: Flink Iss

Re: Janino related question

Hi Gabor, I have checked out your branch and tried debugging WordCountPojo to reproduce the behaviour. I am on a Mac with jdk1.8.0_91. I have received the following error when trying to access the constructors of the class in question: Exception in thread "main" java.lang.VerifyError: (class: org

[VOTE] Release Apache Flink 1.0.3 (RC3)

Dear Flink community, Please vote on releasing the following candidate as Apache Flink version 1.0.3. The commit to be voted on: f3a6b5f1e8d85d10e1449e2f96291408b781 Branch: release-1.0.3-rc3 (see https://git1-us-west.apache.org/repos/asf/flink/?p=flink.git;a=shortlog;h=refs/heads/release-1.

Re: Installing Flink with Homebrew

Hi Eron! Thanks for the brew formula! I agree that flink-daemon doesn't belong in the system path. I think it would make sense to prepend all the Flink startup scripts with "flink-". That way they are easily discoverable. Cheers, Max On Mon, May 9, 2016 at 1:58 AM, Wright, Eron wrote: > Update: