孫金城flink視頻筆記-flink優勢特點

1.流計算亂序問題 無限流count不會有亂序問題,分組統計纔會有亂序問題 watermark是一個時間戳,標識了小於這個時間戳的事件都已經到達了 watermark水印在源位置發射,通過拓撲中的運算符傳播 watermark也是streamElement 和普通數據一起在算子之間傳遞(可以看成一條數據) watermak出發窗口計算,那麼long.Max_value值會在公訴算子後續沒有任何數據
相關文章
相關標籤/搜索