我的理解,flink是一个任务执行引擎,你需要的功能应该是任务调度器吧,比如airflow等。
------------------ Original ------------------ From: Waldeinsamkeit. <1214316...@qq.com> Date: Tue,Jan 5,2021 11:13 AM To: user-zh <user-zh@flink.apache.org> Subject: Re: apache flink 你好!&nbsp; &nbsp; &nbsp; 我想请教下,如果需要在flink中实现自己的流式任务调度器,应该在哪里修改源码呢?据我所知,目前flink并没有提供可插拔的调度器接口。 &nbsp; &nbsp; &nbsp; 望告知!谢谢!