[
https://issues.apache.org/jira/browse/FLINK-14548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-14548:
-----------------------------------
Description:
The stacktrace often looks like:
{code:java}
2019-10-27 23:34:17,257 ERROR org.apache.flink.runtime.taskmanager.Task -
Error while canceling the task Map -> Sink: Unnamed (1/1).
java.util.concurrent.RejectedExecutionException:
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxStateException: Mailbox
is in state CLOSED, but is required to be in state OPEN for put operations. at
org.apache.flink.streaming.runtime.tasks.mailbox.execution.MailboxExecutorImpl.executeFirst(MailboxExecutorImpl.java:75)
at
org.apache.flink.streaming.runtime.tasks.mailbox.execution.MailboxProcessor.sendPriorityLetter(MailboxProcessor.java:176)
at
org.apache.flink.streaming.runtime.tasks.mailbox.execution.MailboxProcessor.allActionsCompleted(MailboxProcessor.java:172)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.cancel(StreamTask.java:540)
at org.apache.flink.runtime.taskmanager.Task$TaskCanceler.run(Task.java:1330)
at java.lang.Thread.run(Thread.java:748) Caused by:
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxStateException: Mailbox
is in state CLOSED, but is required to be in state OPEN for put operations. at
org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailboxImpl.checkPutStateConditions(TaskMailboxImpl.java:199)
at
org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailboxImpl.putHeadInternal(TaskMailboxImpl.java:141)
at
org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailboxImpl.putFirst(TaskMailboxImpl.java:131)
at
org.apache.flink.streaming.runtime.tasks.mailbox.execution.MailboxExecutorImpl.executeFirst(MailboxExecutorImpl.java:73)
... 5 more
{code}
For more details check here:
[https://travis-ci.org/apache/flink/builds/603215648?utm_source=slack&utm_medium=notification]
was:
The stacktrace often looks like:
{{{
2019-10-27 23:34:17,257 ERROR org.apache.flink.runtime.taskmanager.Task - Error
while canceling the task Map -> Sink: Unnamed (1/1).
java.util.concurrent.RejectedExecutionException:
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxStateException: Mailbox
is in state CLOSED, but is required to be in state OPEN for put operations. at
org.apache.flink.streaming.runtime.tasks.mailbox.execution.MailboxExecutorImpl.executeFirst(MailboxExecutorImpl.java:75)
at
org.apache.flink.streaming.runtime.tasks.mailbox.execution.MailboxProcessor.sendPriorityLetter(MailboxProcessor.java:176)
at
org.apache.flink.streaming.runtime.tasks.mailbox.execution.MailboxProcessor.allActionsCompleted(MailboxProcessor.java:172)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.cancel(StreamTask.java:540)
at org.apache.flink.runtime.taskmanager.Task$TaskCanceler.run(Task.java:1330)
at java.lang.Thread.run(Thread.java:748) Caused by:
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxStateException: Mailbox
is in state CLOSED, but is required to be in state OPEN for put operations. at
org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailboxImpl.checkPutStateConditions(TaskMailboxImpl.java:199)
at
org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailboxImpl.putHeadInternal(TaskMailboxImpl.java:141)
at
org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailboxImpl.putFirst(TaskMailboxImpl.java:131)
at
org.apache.flink.streaming.runtime.tasks.mailbox.execution.MailboxExecutorImpl.executeFirst(MailboxExecutorImpl.java:73)
... 5 more
}}}
For more details check here:
[https://travis-ci.org/apache/flink/builds/603215648?utm_source=slack&utm_medium=notification]
> Many tests in the nightly fail during cancellation.
> ---------------------------------------------------
>
> Key: FLINK-14548
> URL: https://issues.apache.org/jira/browse/FLINK-14548
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Coordination, Tests
> Affects Versions: 1.10.0
> Reporter: Kostas Kloudas
> Priority: Major
>
> The stacktrace often looks like:
> {code:java}
> 2019-10-27 23:34:17,257 ERROR org.apache.flink.runtime.taskmanager.Task -
> Error while canceling the task Map -> Sink: Unnamed (1/1).
> java.util.concurrent.RejectedExecutionException:
> org.apache.flink.streaming.runtime.tasks.mailbox.MailboxStateException:
> Mailbox is in state CLOSED, but is required to be in state OPEN for put
> operations. at
> org.apache.flink.streaming.runtime.tasks.mailbox.execution.MailboxExecutorImpl.executeFirst(MailboxExecutorImpl.java:75)
> at
> org.apache.flink.streaming.runtime.tasks.mailbox.execution.MailboxProcessor.sendPriorityLetter(MailboxProcessor.java:176)
> at
> org.apache.flink.streaming.runtime.tasks.mailbox.execution.MailboxProcessor.allActionsCompleted(MailboxProcessor.java:172)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.cancel(StreamTask.java:540)
> at
> org.apache.flink.runtime.taskmanager.Task$TaskCanceler.run(Task.java:1330) at
> java.lang.Thread.run(Thread.java:748) Caused by:
> org.apache.flink.streaming.runtime.tasks.mailbox.MailboxStateException:
> Mailbox is in state CLOSED, but is required to be in state OPEN for put
> operations. at
> org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailboxImpl.checkPutStateConditions(TaskMailboxImpl.java:199)
> at
> org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailboxImpl.putHeadInternal(TaskMailboxImpl.java:141)
> at
> org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailboxImpl.putFirst(TaskMailboxImpl.java:131)
> at
> org.apache.flink.streaming.runtime.tasks.mailbox.execution.MailboxExecutorImpl.executeFirst(MailboxExecutorImpl.java:73)
> ... 5 more
> {code}
>
> For more details check here:
> [https://travis-ci.org/apache/flink/builds/603215648?utm_source=slack&utm_medium=notification]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
