Hi

找到原因了。

问题在于在定义ListState时使用了transient关键字,如下。
 private transient ListState<ObjectNode> state;

去掉了transient之后,问题解决。
虽然不太清粗为何transient会造成这种情况。



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复