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