各位大神,问一个入门问题: 我在flatMap算子里放了一个状态,我需要在sink中拿出来看这个状态,但是发现是null,请问这个是什么原因? 用的是同一个ValueStateDescriptor-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文

各位大神,问一个入门问题: 我在flatMap算子里放了一个状态,我需要在sink中拿出来看这个状态,但是发现是null,请问这个是什么原因? 用的是同一个ValueStateDescriptor

赵慧 2019-01-22 19:04:29 1036

转自钉钉群21789141:
我在flatMap算子里放了一个状态,我需要在sink中拿出来看这个状态,但是发现是null,请问这个是什么原因?
用的是同一个ValueStateDescriptor,状态存储,用的是:FsStateBackend

存储
分享到
取消 提交回答
全部回答(1)
  • 赵慧
    2019-07-17 23:26:25

    云邪:状态只能在当前算子中可见。 你在flatmap中的状态,在sink中是看不到的。

    0 0
云计算
使用钉钉扫一扫加入圈子
+ 订阅

时时分享云计算技术内容,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。

推荐文章
相似问题
推荐课程