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
