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

2022-09-19 Thread Jason (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-29328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17606514#comment-17606514
 ] 

Jason commented on FLINK-29328:
---

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



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

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

2022-09-18 Thread Yun Tang (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-29328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17606408#comment-17606408
 ] 

Yun Tang commented on FLINK-29328:
--

[~Jason_H] Please use English to update this ticket.

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



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

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

2022-09-18 Thread Yanfei Lei (Jira) 


[ 
https://issues.apache.org/jira/browse/FLINK-29328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17606407#comment-17606407
 ] 

Yanfei Lei commented on FLINK-29328:


>From your attachments, this issue is caused by state incompatibility. Did you 
>add some new states when you configurate TTL? 

（从附件中的log来看，是restore前后state不适配引起的。您在配置TTL时在代码中加了新的state吗？

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



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