Till Rohrmann created FLINK-5022:
------------------------------------

             Summary: 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)

Reply via email to