Flink-跟着問題讀源碼：近24小時或者近XX小時這種SlidingEventTimeWindows相關的問題

問題描述 這周接到一個新需求，近24小時的用戶行爲標籤偏好跑分，實現的算法邏輯非常複雜，需要對用戶的各類行爲分別統計並求出比例，再配合各種時間衰減因子、反作弊數據等等。下面針對這次的開發總結下自己的心得，主要是flink window和state方面。 join維表之前預先聚合，否則CP失敗 近24小時的window可以拆分爲5分鐘維度 onTimer watermark的多次申明 timesta

>>阅读原文<<