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

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Not A Bug
• Affects Version/s: 1.14.3
• Component/s: Runtime / State Backends

Environment

• Assignee: Unassigned
• Reporter: Jason
• Created: 19/Sep/22 02:37
• Updated: 18/Aug/23 02:31
• Resolved: 18/Aug/23 02:29

Description

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:

public static final MapStateDescriptor<String, Integer> quantityJudgeStateDescriptor = new MapStateDescriptor<>(
        "quantityJudgeMapState",
        String.class,
        Integer.class); 

• After the error is reported:

public static final MapStateDescriptor<String, RateUnionVo> rateAlgorithmStateProperties = new MapStateDescriptor<>(
        "rateAlgorithmMapState",
        TypeInformation.of(new TypeHint<String>() {
        }),
        TypeInformation.of(new TypeHint<RateUnionVo>() {
        })
); 

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.