[jira] [Commented] (FLINK-29328) 【Flink is having problems using the status expiration setting】

["Yun Tang (Jira)" <ji...@apache.org>]

    [ 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)