我也刚遇到过,是从1.10升级上来的,一个任务可以保存checkpoint,一个任务老是保存失败,然后查看了lib下面的jar,发现有些jar没有升级上来,于是更改了,配置文件还改了state.checkpoints.dir。
希望对你有帮助
发自我的iPhone
-- 原始邮件 --
发件人: 王默
原始邮件 --
>发件人: 王默 发送时间: 2020年11月27日 17:22
>收件人: user-zh 主题: 回复:带有状态的算子保存checkpoint失败
>发件人: 王默 发送时间: 2020年11月27日 17:22
>收件人: user-zh 主题: 回复:带有状态的算子保存checkpoint失败
-2.12.1.jar
> log4j-core-2.12.1.jar
> log4j-slf4j-impl-2.12.1.jar
> flink-metrics-prometheus_2.12-1.11.2.jar
>
> 按时间排了个序,这是最新的包。
>
>
>
> 发自我的iPhone
>
>
> -- 原始邮件 --
> 发件人: 王默 发送时间: 2020年11月27日 18:41
> 收件人: user-zh >
>
t; flink-metrics-prometheus_2.12-1.11.2.jar
>>
>> 按时间排了个序,这是最新的包。
>>
>>
>>
>> 发自我的iPhone
>>
>>
>> -- 原始邮件 --
>> 发件人: 王默 > 发送时间: 2020年11月27日 18:41
>> 收件人: user-zh > >
>> 主题: 回复:Re:回复:带有状态的算子保存checkpoint失败
flink-csv-1.11.2.jar
flink-dist_2.11-1.11.2.jar
flink-json-1.11.2.jar
flink-shaded-zookeeper-3.4.14.jar
flink-table_2.11-1.11.2.jar
flink-table-blink_2.11-1.11.2.jar
log4j-1.2-api-2.12.1.jar
log4j-api-2.12.1.jar
log4j-core-2.12.1.jar
log4j-slf4j-impl-2.12.1.jar
flink-metrics-prometheus_2.12-1.11.2.
-2.12.1.jar
> >> flink-metrics-prometheus_2.12-1.11.2.jar
> >>
> >> 按时间排了个序,这是最新的包。
> >>
> >>
> >>
> >> 发自我的iPhone
> >>
> >>
> >> -- 原始邮件 --
> >> 发件人: 王默 >> 发送时间: