Hi KZ, https://data-artisans.com/blog/real-time-fraud-detection-ing-bank-apache-flink This article seems to be a good example to trigger a new calculation on a running job. Maybe you can get some help from it.
Best Regards, Tony Wei 2017-11-29 4:53 GMT+08:00 zanqing zhang <zanqingzh...@gmail.com>: > Hi All, > > Has anyone done any stream processing driven by a user request? What's the > recommended way of doing this? Or is this completely wrong direction to go > for applications running on top of Flink? > > Basically we need to tweak the stream processing based on parameters > provided by a user, e.g. show me the total # of application failures due to > "ABC", which is provided by the user. We are thinking of starting a flink > job with "ABC" as a parameter but this would result in a huge number of > flink jobs, is there a better way for this? Can we trigger the calculation > on a running job? > > Thanks in advance. > > KZ > >
