You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 12...@qq.com on 2021/01/05 10:00:27 UTC

回复:apache flink

请问需要在flink源码的哪些地方修改才能实现自己的任务调度呢 1214316932 邮箱:1214316932@qq.com 签名由 网易邮箱大师 定制 在2021年01月05日 11:27,Waldeinsamkeit. 写道: 是的,目前是想重写任务调度器,按自己的方式来将任务调度到集群的节点中。 ------------------&nbsp;原始邮件&nbsp;------------------ 发件人:                                                                                                                        "user-zh"                                                                                    <573693104@qq.com&gt;; 发送时间:&nbsp;2021年1月5日(星期二) 中午11:19 收件人:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;; 主题:&nbsp;Re: apache flink 我的理解,flink是一个任务执行引擎,你需要的功能应该是任务调度器吧,比如airflow等。 ------------------ Original ------------------ From: Waldeinsamkeit. <1214316932@qq.com&amp;gt; Date: Tue,Jan 5,2021 11:13 AM To: user-zh <user-zh@flink.apache.org&amp;gt; Subject: Re: apache flink 你好!&amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; 我想请教下,如果需要在flink中实现自己的流式任务调度器,应该在哪里修改源码呢?据我所知,目前flink并没有提供可插拔的调度器接口。 &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; 望告知!谢谢!