sreenath-kamath commented on issue #9134: URL: https://github.com/apache/airflow/issues/9134#issuecomment-683371059
Why not use the flink REST API's to submit the job and store the job_id in the xcom variable and exit the process, https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/rest_api.html. Incase the user wants to poll for the status of the job in the dag a `Sensor` can also be written which takes the job id as an argument and ensures that the job is still running. wdyt ? ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
