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

Reply via email to