Hi everyone, When testing Flink statefun, the job eventually throws the following exception after failing to reach the endpoint or if the endpoint fails after the exponentially increasing delay.
java.util.concurrent.RejectedExecutionException: org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailbox$MailboxClosedException: Mailbox is in state CLOSED, but is required to be in state OPEN for put operations. How do I recover from this state? Thank you. Regards, Hady
