前言
公司的一個(gè)大數(shù)據(jù)項(xiàng)目是通過(guò)使用spark每隔一分鐘統(tǒng)計(jì)一次15分鐘內(nèi)的日志信息,一般40~50s左右就可以統(tǒng)計(jì)完,但是偶爾會(huì)出現(xiàn)某幾次任務(wù)時(shí)間超出一分鐘的,而我的需求就是定位問(wèn)題與解決問(wèn)題,這里就特意寫(xiě)個(gè)文集來(lái)記錄自己學(xué)習(xí)該大數(shù)據(jù)日志分析系統(tǒng)的心得
目錄
1.系統(tǒng)架構(gòu)
2.環(huán)境搭建
2.1本地環(huán)境下kafka批量導(dǎo)入數(shù)據(jù)
2.2 kafka-manager的安裝與配置
3.1 Spark Streaming 性能調(diào)優(yōu)(一): 解決并行度
3.2 Spark Streaming 性能調(diào)優(yōu)(二): 解決task傾斜
