问题是您尝试访问方法中的键控状态
open()。
键控状态为每个键维护一个状态实例。在您的示例中,您正在使用
MapState。因此
MapState,每个密钥都有一个实例。访问状态时,您将始终获得与当前处理记录的键对应的状态实例。在一个
MapFunction(如您的示例中)这将是传递给该
map()方法的记录。
由于
open()未与记录一起调用,因此当前键
open()为
null,因此无法访问键控状态。
欢迎分享,转载请注明来源:内存溢出
问题是您尝试访问方法中的键控状态
open()。
键控状态为每个键维护一个状态实例。在您的示例中,您正在使用
MapState。因此
MapState,每个密钥都有一个实例。访问状态时,您将始终获得与当前处理记录的键对应的状态实例。在一个
MapFunction(如您的示例中)这将是传递给该
map()方法的记录。
由于
open()未与记录一起调用,因此当前键
open()为
null,因此无法访问键控状态。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)