Matthias Pohl created FLINK-31995:
-------------------------------------
Summary: DirectExecutorService doesn't follow the ExecutorService
contract throwing a RejectedExecutionException in case it's already shut down
Key: FLINK-31995
URL: https://issues.apache.org/jira/browse/FLINK-31995
Project: Flink
Issue Type: Bug
Components: Runtime / Coordination
Affects Versions: 1.16.1, 1.17.0, 1.18.0
Reporter: Matthias Pohl
We experienced an issue where we tested behavior using the
{{DirectExecutorService}} with the {{ExecutorService}} being shutdown already.
The tests succeeded. The production code failed, though, because we used a
singleThreadExecutor for which the task execution failed after the executor was
stopped. We should add this behavior to the {{DirectExecutorService}} as well
to make the unit tests be closer to the production code.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
