-----------
> *From:* Pawel Bartoszek
> *Sent:* Wednesday, October 24, 2018 23:11
> *To:* User
> *Subject:* Flink weird checkpointing behaviour
>
> Hi,
>
> We have just upgraded to Flink 1.5.2 on EMR from Flink 1.3.2. We have
> noticed th
e program’s state will eventually reflect every record
from the data stream exactly once. Note that there is a switch to ...
ci.apache.org
Best
Yun Tang
From: Pawel Bartoszek
Sent: Wednesday, October 24, 2018 23:11
To: User
Subject: Flink weird checkpointing behavi
Hi,
We have just upgraded to Flink 1.5.2 on EMR from Flink 1.3.2. We have
noticed that some checkpoints are taking a very long time to complete some
of them event fails with exception
Caused by: akka.pattern.AskTimeoutException: Ask timed out on
[Actor[akka://flink/user/jobmanager_0#-665361795]]
