Hi Martin,
I did some activiti development so your mail caught my attention :)
I don't think I understand what are you trying to achieve - where is
process you're simulating, where is simulation running and where is
place for Flink. Do you want to invoke Flink (batch job I suppose?) from
Flowable process? Or do you want to run simulations of BPMN process as
Flink job?
thanks,
maciek
On 16/01/2018 22:29, Martin Grofčík wrote:
Hi,
I want to implement flowable (BPMN platform - www.flowable.org
<http://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
