有一個(gè)具體的interval join需求,兩條流使用ROWTIME事件時(shí)間,一條流的數(shù)據(jù)很多,20條/秒,一條流數(shù)據(jù)量很小,5條/天,我們?cè)谶\(yùn)行過程中出現(xiàn)了checkpoint狀態(tài)無線增大的情況,請(qǐng)問這個(gè)怎么解?
Flink 流流關(guān)聯(lián)( Interval Join)總結(jié)Flink對(duì)流流JOIN的支持 Flink對(duì)于join的支持有多種支持,可參考 Flink Join類型, 本文主要討論Time interval join支持Table A...