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