You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/08 14:30:58 UTC
[jira] [Resolved] (FLINK-5022) Suppress RejectedExecutionException
when the Executor is shut down
[ https://issues.apache.org/jira/browse/FLINK-5022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Stephan Ewen resolved FLINK-5022.
---------------------------------
Resolution: Fixed
Fixed via d3908241323f5de3d454c7daf560faed49b3c779
> Suppress RejectedExecutionException when the Executor is shut down
> ------------------------------------------------------------------
>
> Key: FLINK-5022
> URL: https://issues.apache.org/jira/browse/FLINK-5022
> Project: Flink
> Issue Type: Improvement
> Affects Versions: 1.2.0
> Reporter: Till Rohrmann
> Assignee: Till Rohrmann
> Priority: Minor
> Fix For: 1.2.0
>
>
> The {{JobManager}} shuts down its {{ExecutionService}} when the actor is stopped. This causes the problem that the execution service which is used to run future callbacks is finished before the actor has completely terminated. Due to this there might be rpc answers which cause another {{Runnable}} to be submitted to the {{ExecutionService}}. This causes {{RejectedExecutionExceptions}} to be thrown.
> The underlying problem is that the {{JobManager}} should not stop the {{ExecutionService}} before the actor has been terminated. This will be changed in Flip-6 anyway. In the meantime to suppress these exceptions, it will be checked whether the {{ExecutionService}} has been shut down and only if not, exceptions will be logged.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)