重寫StreamSource,假設(shè)消費(fèi)kafka,是直接用flinkKafkaConsumer還是要自定義你上面說的StreamSouce?
還是消費(fèi)kafka和之前一樣,只是把這個(gè)重寫StreamSource打包放到flink的jar包中?并對source.idle.timeout.ms這個(gè)參數(shù)賦值?
flink數(shù)據(jù)傾斜問題解決與源碼研究1 遇到問題 flink實(shí)時(shí)程序在線上環(huán)境上運(yùn)行遇到一個(gè)很詭異的問題,flink使用eventtime讀取kafka數(shù)據(jù)發(fā)現(xiàn)無法觸發(fā)計(jì)算。經(jīng)過代碼打印查看后發(fā)現(xiàn)十個(gè)并行度執(zhí)行...