> > 这个状态变量是否需要用transient来修饰 ValueState 再 Rich fuction 的 open 方法中被初始化，不应该被序列化和反序列化，建议使用 transient 来修饰。 但实际上自定义函数的序列化、反序列化只在任务部署阶段执行，而且初始状态下 ValueState 的值是 null，所以不使用 transient 关键字也不会有太大的影响。
以及什么情况下flink代码中需要用transient来修饰变量，什么情况下不用transient来修饰 理解自定义函数的序列化、反序列化是在任务部署阶段执行之后，这个问题就比较好回答了。 如果你的变量在是函数的 open 方法内初始化的，那应该增加 transient 关键字来表明该字段不需要参与序列化 Best, Weihua On Tue, Jun 13, 2023 at 1:10 PM Paul <18751805...@163.com> wrote: > 在flink处理函数中定义一个状态变量，比如private ValueState<String> > vs；这个状态变量是否需要用transient来修饰，为什么呢？以及什么情况下flink代码中需要用transient来修饰变量，什么情况下不用transient来修饰？请大家指教 > > >
