[
https://issues.apache.org/jira/browse/FLINK-29328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621520#comment-17621520
]
Yun Tang commented on FLINK-29328:
----------------------------------
First of all, the problem would only occur during state restoring. The state
descriptors (quantityJudgeStateDescriptor and rateAlgorithmStateProperties) you
offered is totally different, and they must meet the migration problem due to
incompatible serializers.
> 【Flink is having problems using the status expiration setting】
> --------------------------------------------------------------
>
> Key: FLINK-29328
> URL: https://issues.apache.org/jira/browse/FLINK-29328
> Project: Flink
> Issue Type: Bug
> Components: Runtime / State Backends
> Affects Versions: 1.14.3
> Environment: !报错1.jpg!!报错2.jpg!
> Reporter: Jason
> Priority: Minor
> Attachments: 报错1.jpg, 报错2.jpg
>
>
> I am flink1.14.3 based version, the following problems when using the finish
> a Flink homework for the first time, add the TTL Settings, and then start the
> homework, automatic recovery at a particular time homework problems, the
> following error, specific see attachment pictures, eventually repair method
> is, in creating a state descriptor is to change the wording, As follows:
> * Before the error:
> {code:java}
> public static final MapStateDescriptor<String, Integer>
> quantityJudgeStateDescriptor = new MapStateDescriptor<>(
> "quantityJudgeMapState",
> String.class,
> Integer.class); {code}
> * After the error is reported:
> {code:java}
> public static final MapStateDescriptor<String, RateUnionVo>
> rateAlgorithmStateProperties = new MapStateDescriptor<>(
> "rateAlgorithmMapState",
> TypeInformation.of(new TypeHint<String>() {
> }),
> TypeInformation.of(new TypeHint<RateUnionVo>() {
> })
> ); {code}
> After changing this way of writing, the test did not appear the above
> problem, do not know whether it is a bug problem, raise this problem, in
> order to trace the source.
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
