Fwd: FLINK TABLE API UDAF QUESTION, For heap backends, the new state serializer must not be incompatible

-- Forwarded message - 发件人： orlando qi Date: 2019年8月23日周五 上午10:44 Subject: FLINK TABLE API UDAF QUESTION, For heap backends, the new state serializer must not be incompatible To: Hello everyone: I defined a UDAF function when I am using the FLINK TABLE API to achieve the

FLINK TABLE API UDAF QUESTION, For heap backends, the new state serializer must not be incompatible

Hello everyone: I defined a UDAF function when I am using the FLINK TABLE API to achieve the aggregation operation. There is no problem with the task running from beginning in cluster. But it throws an exception when it is restart task from checkpoint,How can I resolve it ? java.lang.Runtime