You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Xintong Song (Jira)" <ji...@apache.org> on 2022/10/20 07:29:00 UTC

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

     [ https://issues.apache.org/jira/browse/FLINK-29328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Xintong Song updated FLINK-29328:
---------------------------------
    Component/s: Runtime / State Backends
                     (was: API / DataStream)

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