Re: Alter Flink's execution graph at run-time

2016-05-31 Thread Xtra Coder
Thanks, altering via pause/update/resume is OK, at least for now. Will try it on practice. Just in case - question was inspired by Apache NiFi. If you haven't seen this https://www.youtube.com/watch?v=sQCgtCoZyFQ - at 29:10. I would say such thing is a must have feature in "production" where stopp

Re: Alter Flink's execution graph at run-time

2016-05-31 Thread Ufuk Celebi
Hey, currently this is not possible. You can use savepoints (https://ci.apache.org/projects/flink/flink-docs-release-1.0/apis/streaming/savepoints.html) to stop the job and then resume with the altered job version. There are plans to allow dynamic rescaling of the execution graph, but I think they