问题是您尝试访问方法中的键控状态
open()。
键控状态为每个键维护一个状态实例。在您的示例中,您正在使用
MapState。因此
MapState,每个密钥都有一个实例。访问状态时,您将始终获得与当前处理记录的键对应的状态实例。在一个
MapFunction(如您的示例中)这将是传递给该
map()方法的记录。
由于
open()未与记录一起调用,因此当前键
open()为
null,因此无法访问键控状态。

问题是您尝试访问方法中的键控状态
open()。
键控状态为每个键维护一个状态实例。在您的示例中,您正在使用
MapState。因此
MapState,每个密钥都有一个实例。访问状态时,您将始终获得与当前处理记录的键对应的状态实例。在一个
MapFunction(如您的示例中)这将是传递给该
map()方法的记录。
由于
open()未与记录一起调用,因此当前键
open()为
null,因此无法访问键控状态。