Hi 找到原因了。
问题在于在定义ListState时使用了transient关键字,如下。 private transient ListState<ObjectNode> state; 去掉了transient之后,问题解决。 虽然不太清粗为何transient会造成这种情况。 -- Sent from: http://apache-flink.147419.n8.nabble.com/
Hi 找到原因了。
问题在于在定义ListState时使用了transient关键字,如下。 private transient ListState<ObjectNode> state; 去掉了transient之后,问题解决。 虽然不太清粗为何transient会造成这种情况。 -- Sent from: http://apache-flink.147419.n8.nabble.com/