[ https://issues.apache.org/jira/browse/FLINK-29328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17606514#comment-17606514 ]
Jason edited comment on FLINK-29328 at 9/19/22 9:53 AM: -------------------------------------------------------- Yanfei Lei Thanks for the quick replay. No, my job is brand new and has not been changed and started with a brand new job deployment. 我的作业是全新的,没有改变状态,是以新作业启动的。 During this run, only an automatic restart of the job occurred and no state changes were made. 并且,在作业运行过程中,并没有对作业进行过状态的修改。 was (Author: JIRAUSER295895): No, my job is brand new and has not been changed and started with a brand new job deployment. During this run, only an automatic restart of the job occurred and no state changes were made. > 【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: API / DataStream > 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)