flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-5022) Suppress RejectedExecutionException when the Executor is shut down
Date Mon, 07 Nov 2016 17:20:59 GMT

    [ https://issues.apache.org/jira/browse/FLINK-5022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15644772#comment-15644772

ASF GitHub Bot commented on FLINK-5022:

Github user StephanEwen commented on the issue:

    Merging this...

> 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

View raw message