
SparkStreaming使用mapWithState時,設置timeout()無法生效問題解決方案
- 2021 年 4 月 13 日
- 筆記
前言 当我在测试SparkStreaming的状态操作mapWithState算子时,当我们设置timeout(3s)的时候,3s过后数据还是不会过期,不对此key进行操作,等到30s左右才会清除过期的数据。 百度了很久,关于timeout的资料很少,更没有解决这个问题的文章,所以说,百度也不是万能 …
Continue Reading
前言 当我在测试SparkStreaming的状态操作mapWithState算子时,当我们设置timeout(3s)的时候,3s过后数据还是不会过期,不对此key进行操作,等到30s左右才会清除过期的数据。 百度了很久,关于timeout的资料很少,更没有解决这个问题的文章,所以说,百度也不是万能 …
Continue Reading