Flink键控流键为空

Flink键控流键为空,第1张

Flink键控流键为空

问题是您尝试访问方法中的键控状态

open()

键控状态为每个键维护一个状态实例。在您的示例中,您正在使用

MapState
。因此
MapState
,每个密钥都有一个实例。访问状态时,您将始终获得与当前处理记录的键对应的状态实例。在一个
MapFunction
(如您的示例中)这将是传递给该
map()
方法的记录。

由于

open()
未与记录一起调用,因此当前键
open()
null
,因此无法访问键控状态。



欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/zaji/4908581.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-11-12
下一篇 2022-11-12

发表评论

登录后才能评论

评论列表(0条)

保存