Hi Experts, We are planning to migrate our flink jobs from per-job mode to application mode in our platform. Our jobs are basically SQL scripts so we have some custom Java code to leverage Flink's SQL and Table API to build the execution environment and execute the jobs on Yarn. We would like to keep the current flow in our platform so we are looking for a way to run Flink SQL in application mode via some Java code. Does this seem to be a good approach to follow or should we look for a better solution? If this is a good choice, is there any API to support this?
Thanks Tamas