[
https://issues.apache.org/jira/browse/FLINK-29328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason updated FLINK-29328:
--------------------------
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:
{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.
was:
本人是基于flink1.14.3的版本使用时出现如下的问题，在第一次完成一个Flink作业时，添加了TTL的设置，然后启动作业后，在某一次作业出现问题自动恢复时，报如下错误，具体见附件图片，最终修复的方法是，在创建状态描述器是改变了写法，如下所示：
报错之前的写法：
{code:java}
public static final MapStateDescriptor<String, Integer>
quantityJudgeStateDescriptor = new MapStateDescriptor<>(
"quantityJudgeMapState",
String.class,
Integer.class); {code}
报错之后的写法：
{code:java}
public static final MapStateDescriptor<String, RateUnionVo>
rateAlgorithmStateProperties = new MapStateDescriptor<>(
"rateAlgorithmMapState",
TypeInformation.of(new TypeHint<String>() {
}),
TypeInformation.of(new TypeHint<RateUnionVo>() {
})
); {code}
改成之后的这种写法后，测试没有出现上述的问题，暂不知道是否是bug问题，提此问题，以追根溯源。
> 【flink在使用状态过期设置时出现问题】
> ---------------------
>
> 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)
