感谢唐云老师的回复,问题已经找到了,是我们切换了statebackend为filesystem时使用的state 清除策略配置有误导致的,这样设置清除策略cleanupIncrementally(10000, true) 执行cp就会非常慢,后来我们修改成了 .cleanupIncrementally(100, false)这样执行cp速度就马上上来了,感谢各位的帮助
- Flink任务大状态使用filesystem反压 Yang Peng
- Re: Flink任务大状态使用filesystem反压 Yun Tang
- Re: Flink任务大状态使用filesystem反压 Yang Peng
- Re: Flink任务大状态使用filesystem反压 Yun Tang
- Re: Flink任务大状态使用filesystem反压 Yang Peng
