hi.

这种情况下,最好查看一下是否发生了反压,同时看看日志之中是否有相关的异常信息。

Best,
Shengkai

amber_...@qq.com.INVALID <amber_...@qq.com.invalid> 于2022年6月21日周二 09:43写道:

> 您好!
>     我使用flink1.14.4,sqlserver-cdc-2.2.1,yarn-per-job模式提交任务;
>     当我提交普通数据同步任务时,一切正常;
>     当我提交JOIN+聚合任务时,checkpoint无法正常工作,具体表现为无任何checkpoint记录,且Task Managed
> Memory使用率始终是100%;
>     以下是我的checkpoint配置:
>
>
>     我尝试增加Task Managed内存,但使用率总是100%;
>     当我关闭增量检查点时,无任何变化;
>     当我将State Backend切换为hashmap时,Managed Memory使用率回归正常,但checkpoint仍然无法工作;
>
> 期待你的回复。
> 祝好!
> ------------------------------
> amber_...@qq.com
>

回复