遇到的問題:
機器故障不可避免,flink單機故障自動恢復(fù)能力不足
機器quota不均衡導(dǎo)致資源碎片
磁盤 內(nèi)存 CPU等異常難以100%檢測到
作業(yè)依賴的agent沒有托管到y(tǒng)arn,發(fā)生故障仍然會調(diào)度

異常節(jié)點的處理邏輯
遇到的問題
作業(yè)啟動時間不穩(wěn)定
作業(yè)啟動時間靠經(jīng)驗和用戶的反饋
作業(yè)要求實時性高,要求重啟時間要盡可能短

flink啟動流程

慢節(jié)點機制

mode
調(diào)度器

image.png
重啟

image.png