Hi, I want to implement flowable (BPMN platform - www.flowable.org) <-> flink integration module. The motivation is to execute process simulations with flink (simple simulation experiment example https://gromar01.wordpress.com/2017/11/07/will-we-meet-our-kpis/). I was able to create
Flink provides REST API through which I can easily create a job and monitor its execution. wordCountProcess.PNG (15K) <https://mail.google.com/mail/ca/u/0/?ui=2&ik=b95e673dbd&view=att&th=16100d25b4542764&attid=0.1&disp=safe&realattid=f_jci4ya9t0&zw> at the end I can encapsulate whole process into one task (e.g. Execute flink job) which will do the same in java code. In fact I have no experience with flink that's why I can imagine only process steps to: 1. create flink job 2. monitor its state Question 1: Can you propose another useful process steps? (e.g. to download results, upload datasets, .....) (Provide me a link how I can proceed with their implementation, please) Question 2: The problem with the process is that it is always checking job state. I would prefer to add a hook at the end of flink job execution to call flowable rest API to notify process instance about the job finished (failed....) events. The way which I have found is to implement rest end point org.apache.flink.runtime.webmonitor.handlers.JarPlanHandler which calls flowable rest api at the end of flink job execution. What I would prefer is to make something like wrapper around the main class to execute flowable rest call at the end. Can you provide me a hint how to implement this wrapper please? Thank you in advance for the answer. Regards Martin
