[jira] [Created] (FLINK-2407) Add an API switch to select between exactly once and at least once fault tolerance

Stephan Ewen created FLINK-2407: --- Summary: Add an API switch to select between exactly once and at least once fault tolerance Key: FLINK-2407 URL: https://issues.apache.org/jira/browse/FLINK-2407

[jira] [Created] (FLINK-2406) Abstract BarrierBuffer to an exchangeable BarrierHandler

Stephan Ewen created FLINK-2406: --- Summary: Abstract BarrierBuffer to an exchangeable BarrierHandler Key: FLINK-2406 URL: https://issues.apache.org/jira/browse/FLINK-2406 Project: Flink Issue

add some new api to the scheduler in the job manager

hi guysFlink must take over all the resources all the time. That wastes resources sometime especially in the sharing cluster.For example when using Flink on Yarn the resource can't be returned back to RM even if no graph is running.So I want to know: Is it possible to add some apis in the

Re: add some new api to the scheduler in the job manager

Hi, I think for more details on giving back resources of a running cluster we have to wait for Robert's opinion. In the mean time, you can also just run a single job that will bring up some yarn containers and then release them afterward using this:

[ANNOUNCE] Distributed stream and graph processing with Apache Flink Bay Area meetup

Hi All, Please join us at another Bay Area Apache Flink meetup, this time will focus bit on distributed streaming and graph processing: http://www.meetup.com/Bay-Area-Apache-Flink-Meetup/events/224189524 We have special guests speakers of PMCs and committers of Apache Flink: Gyula, Vasia, and

Getting an eeror while running the code

bin/flink run -c com.hello.flink.StreamData /home/a544403/Flinkstream.jar org.apache.flink.client.program.ProgramInvocationException: The program's entry point class 'com.hello.flink.StreamData' could not be loaded due to a linkage failure. at

Re: Getting an eeror while running the code

Hi, print() method runs the program immediately. After execution, there is no sink in the program. You should remove calling execute() method after calling print() method. There is more detail description [1][2] in Flink documentation. I hope that this helps. Regards, Chiwan Park [1]