flink 有狀態udf 引發血案一

場景redis 最近在作一個畫像的任務，sql實現的，其中有一個udf，會作不少事情，包括將從redis讀出歷史值加權，並將中間結果和加權後的結果更新到redis。sql 你們都知道，flink 是能夠支持事件處理的，也就是能夠沒有時間的概念，那麼在聚合，join等操做的時候，flink內部會維護一個狀態，假如此時你也用redis維護了歷史狀態，也便是相似 result = currentStat

>>阅读原文<<