Hi Sanket,
Yes, that's correct.
Thanks,
Martijn
On Fri, Jul 7, 2023 at 8:00 PM Sanket Agrawal
wrote:
> Hello Martijn,
>
> Thank you for your reply. Even for the newer versions of Flink it’s
> recommended to use MailboxExecutor in place of StreamTask’s
> getCheckpointLock() method, right?
>
>
Hi Sanket,
Have you read the release notes for Flink 1.11 at
https://nightlies.apache.org/flink/flink-docs-release-1.11/release-notes/flink-1.11.html#removal-of-deprecated-streamtaskgetcheckpointlock-flink-12484
?
Given that Flink 1.11 is a version that's no longer supported in the Flink
community
Hello,
I'm trying to upgrade flink from 1.8 to 1.11 and StreamTask's
getcheckpointlock method is removed and the new recommendation is to use
MailboxExecutor. Currently we're using it like:
synchronized(operator.getContainingTask.getCheckpointLock()) {
// perform some operation
}
The pur
