參數(shù)
- ?jobmanager.memory.process.size:對 JobManager 進程可使用到的全部內(nèi)存進行配置, 包括 JVM元空間和其他開銷,默認(rèn)為 1600M,可以根據(jù)集群規(guī)模進行適當(dāng)調(diào)整。
- ? taskmanager.memory.process.size:對 TaskManager 進程可使用到的全部內(nèi)存進行配置,包括 JVM 元空間和其他開銷,默認(rèn)為 1600M,可以根據(jù)集群規(guī)模進行適當(dāng)調(diào)整。
- ? taskmanager.numberOfTaskSlots:對每個 TaskManager 能夠分配的 Slot 數(shù)量進行配置,
默認(rèn)為 1,可根據(jù) TaskManager 所在的機器能夠提供給 Flink 的 CPU 數(shù)量決定。所謂
Slot 就是 TaskManager 中具體運行一個任務(wù)所分配的計算資源。 - ? parallelism.default:Flink 任務(wù)執(zhí)行的默認(rèn)并行度,優(yōu)先級低于代碼中進行的并行度配
置和任務(wù)提交時使用參數(shù)指定的并行度數(shù)量。
任務(wù)(Tasks)和任務(wù)槽(Task Slots)
- 任務(wù)槽(Task Slots)
Flink 中每一個 worker(也就是 TaskManager)都是一個 JVM 進程,它可以啟動多個獨立的線程,來并行執(zhí)行多個子任務(wù)(subtask)。
如果想要執(zhí)行 5 個任務(wù),并不一定非要 5 個 Ta文章來源地址http://www.zghlxwxcb.cn/news/detail-631095.html
文章來源:http://www.zghlxwxcb.cn/news/detail-631095.html
到了這里,關(guān)于flink-conf.yaml的參數(shù)的文章就介紹完了。如果您還想了解更多內(nèi)容,請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章,希望大家以后多多支持TOY模板網(wǎng)!