apache flink

[Waldeinsamkeit.]

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

[kcz]

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





------------------ Original ------------------
From: Waldeinsamkeit. <[hidden email]&gt;
Date: Tue,Jan 5,2021 11:13 AM
To: user-zh <[hidden email]&gt;
Subject: Re: apache flink



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

[Waldeinsamkeit.]

是的，目前是想重写任务调度器，按自己的方式来将任务调度到集群的节点中。




------------------&nbsp;原始邮件&nbsp;------------------
发件人:                                                                                                                        "user-zh"                                                                                    <[hidden email]&gt;;
发送时间:&nbsp;2021年1月5日(星期二) 中午11:19
收件人:&nbsp;"user-zh"<[hidden email]&gt;;

主题:&nbsp;Re: apache flink



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





------------------ Original ------------------
From: Waldeinsamkeit. <[hidden email]&amp;gt;
Date: Tue,Jan 5,2021 11:13 AM
To: user-zh <[hidden email]&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; 望告知！谢谢！

[Waldeinsamkeit.]

请问需要在flink源码的哪些地方修改才能实现自己的任务调度呢 1214316932 邮箱：[hidden email] 签名由 网易邮箱大师 定制 在2021年01月05日 11:27，Waldeinsamkeit. 写道： 是的，目前是想重写任务调度器，按自己的方式来将任务调度到集群的节点中。 ------------------&nbsp;原始邮件&nbsp;------------------ 发件人:                                                                                                                        "user-zh"                                                                                    <[hidden email]&gt;; 发送时间:&nbsp;2021年1月5日(星期二) 中午11:19 收件人:&nbsp;"user-zh"<[hidden email]&gt;; 主题:&nbsp;Re: apache flink 我的理解，flink是一个任务执行引擎，你需要的功能应该是任务调度器吧，比如airflow等。 ------------------ Original ------------------ From: Waldeinsamkeit. <[hidden email]&amp;gt; Date: Tue,Jan 5,2021 11:13 AM To: user-zh <[hidden email]&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; 望告知！谢谢！