您好,
在單機模式使用maven執行專案時,會自動啟動MiniCluster,
我想請問在這種情形下,預設是配置一個JobManager以及一個TaskManager嗎?
找了一下文件中並沒有相關的說明。
感謝!
是这样的。
这里的配置可以参考[1][2]两个类,具体你 Maven 启动的代码路径还跟[3][4]有关。
这边可能确实文档比较缺失。可以看下配置传递的路径,TM 的数量还有 RPC 的共享格式等配置,至少编程接口上都是可以配的。
Best,
tison.
[1]
https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java
[2]
https://github.com/apache/flink/
在zeppelin也集成了flink的local 模式,可以通过设置 local.number-taskmanager 和
flink.tm.slot来设置tm和slot的数目,
具体可以参考这个视频 https://www.bilibili.com/video/BV1Te411W73b?p=3
tison 于2020年5月24日周日 下午9:46写道:
> 是这样的。
>
> 这里的配置可以参考[1][2]两个类,具体你 Maven 启动的代码路径还跟[3][4]有关。
>
> 这边可能确实文档比较缺失。可以看下配置传递的路径,TM 的数量还有 RPC 的共享格式等配置,至少编程接口
非常感謝,我再研究一下!
Jeff Zhang 於 2020年5月24日 週日 下午9:52寫道:
> 在zeppelin也集成了flink的local 模式,可以通过设置 local.number-taskmanager 和
> flink.tm.slot来设置tm和slot的数目,
> 具体可以参考这个视频 https://www.bilibili.com/video/BV1Te411W73b?p=3
>
> tison 于2020年5月24日周日 下午9:46写道:
>
> > 是这样的。
> >
> > 这里的配置可以参考[1][2]两个类,具体你 Maven 启动的代码路径