• 写点啥呢
    2020-10-16
    请问老师，UnionListState和BroadcastState从图上看都是会把状态复制到每个task一份，是不是它们两个在功能上是不是有重叠呢？

    作者回复: 后面专门讲解了BroadcastState

    
    
  • zj
    2021-04-12
    为什么keyedstate不需要支持重新分布
    共 2 条评论
    1
  • Allan
    2021-03-09
    保持状态，需要我们实现checkpointfunction算子，去实现快照保持，初始化，从而可以恢复。
    
    1
  • 福
    2022-02-17
    张老师，不是 说operator stage 只有3种类型嘛，广播，liststage，uninliststage,这3种，为什么这个教程中，有个ReducingStage 这种类型
    
    
  • 小进
    2022-01-05
    老师，请教一下，对于案例中描述的Buffering sink，我想用这种方式实现数据批量写入数据库，但是存在的问题是如果最新的一批数据没有到达threshold阈值，后续又没有新数据到来，那这样的话这批数据会永远被留在状态里，我考虑过增加计时器定时触发，但是定时器的触发又不能和threshold阈值触发放在同一个方法里，对于这个问题有什么好的解决办法嚒
    
    