SteNicholas opened a new issue #9134: URL: https://github.com/apache/airflow/issues/9134
**Description** Airflow currently supports Spark operators for kicking off a spark-submit job. In real-time computing or online machine learning scenarios, Flink operator could be designed to submit flink job in streaming workflow. **Use case / motivation** Airflow coud supports definition of `FlinkSubmitOperator` for DAG composed of multiple Flink jobs. `FlinkSubmitOperator` is designed to introduce the operator that kicks off a flink-submit task, and provides corresponding to JDBC and SQL operators. **Related Issues** N/A ---------------------------------------------------------------- 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]
