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]
https:/
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:
https://ci.apache.org/projects/flink/flink-docs-r
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
org.apache.flink.client.program.PackagedProgra
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 sche
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 Pa
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
Pr
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 Ty
