Hi All! I am looking into implementing long running background tasks inside an operator using the

MailboxExecutor

and I want to make sure I can yield to incoming records (default action) and checkpoint barriers. Is there a way to do this? It seems as though

yield

and

tryYield

only yield to other Mailbox items. The only clean option I see is to do what the

ContinuousFileReaderOperator

does and cast

MailboxExecutor

to

MailboxExecutorImpl

so I can check

isIdle

, then suspend my task and requeue it in the mailbox. Are there any accepted patterns to do this? I am using Scala on Flink 1.16.3 Thanks!