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 (it's 3 years old at this point), I don't think there will be a lot of options here outside those mentioned in the release notes.
Best regards, Martijn On Fri, Jul 7, 2023 at 5:35 AM Sanket Agrawal <sagrawal0...@gmail.com> wrote: > 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 purpose of getCheckpointLock in above code is to get the lock so that > the operation can be performed synchronously without interference from any > other checkpoint. > > Since MailboxExecutor is mainly used for asynchronization, I'm finding it > difficult to convert the above piece of code to something that uses > MailboxExecutor. > > I hope my problem makes sense, and I would really appreciate it if someone > could help me to move forward with this problem. > > Thank you >