Re: 回复: flink使用StateBackend问题

2019-09-03 文章 Yun Tang
作业反压的话,barrier一直都流不到下游,容易造成checkpoint超时。 建议分享一下作业webUI上的checkpoint 信息。 祝好 唐云 From: Wesley Peng Sent: Tuesday, September 3, 2019 15:44 To: user-zh@flink.apache.org Subject: Re: 回复: flink使用StateBackend问题 on 2019/9/3 15:38, 守护 wrote

Re: 回复: flink使用StateBackend问题

2019-09-03 文章 Wesley Peng
on 2019/9/3 15:38, 守护 wrote: org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Received late message for now expired checkpoint attempt 3 from 24674987621178ed1a363901acc5b128 of job fd5010cbf20501339f1136600f0709c3. 请问这个是什么问题呢?