我的理解,flink是一个任务执行引擎,你需要的功能应该是任务调度器吧,比如airflow等。





------------------ Original ------------------
From: Waldeinsamkeit. <1214316...@qq.com&gt;
Date: Tue,Jan 5,2021 11:13 AM
To: user-zh <user-zh@flink.apache.org&gt;
Subject: Re: apache flink



你好!&amp;nbsp; &amp;nbsp; &amp;nbsp; 
我想请教下,如果需要在flink中实现自己的流式任务调度器,应该在哪里修改源码呢?据我所知,目前flink并没有提供可插拔的调度器接口。
&amp;nbsp; &amp;nbsp; &amp;nbsp; 望告知!谢谢!

回复