Re: Service frontend as a source and sink

2016-05-10 Thread Till Rohrmann
Hi Maxim, Flink does not execute the operators in the JobManager but the TaskManager. The JobManager's role is the orchestration of the Flink job. Unfortunately, there is currently no way to explicitly control the deployment of tasks to TaskManagers with different roles. However, Flink supports s

Service frontend as a source and sink

2016-05-09 Thread Maxim
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