Hey, I need some output regarding this situation. I have a flink batch job that needs to run based on a trigger. By trigger I meant suppose there is a FASTAPI endpoint exposed for clients to post "submit", as soon as that happens, the job needs to be submitted! We are using Flink-Kubernetes-Operator and its on Session Cluster mode. I can't really use cron, because the its aperiodic as you can see. What will be the flink way to achieve this? Has anyone solved this kind of use cases? If so how? Love to know your thoughts! Thanks

If you are using flink operator, the you can have a flink session cluster and submit new job via flink session job k8s custom resource.