[jira] [Created] (FLINK-29328) 【flink在使用状态过期设置时出现问题】

Sun, 18 Sep 2022 19:38:04 -0700 

Jason created FLINK-29328:
-----------------------------

             Summary: 【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
         Attachments: 报错1.jpg, 报错2.jpg

本人是基于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问题，提此问题，以追根溯源。

 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to