[
https://issues.apache.org/jira/browse/FLINK-32039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32039:
----------------------------------
Description:
{{ExecutorServiceResource}} and {{ExecutorServiceExtension}}'s shutdown
mechanism doesn't include a forced shutdown. The shutdown is triggered but no
verification happens whether the threads were actually shut down.
This issue adds a graceful shutdown to the resource/extension implementation
(compare with
[ExecutorUtils.gracefulShutdown|https://github.com/apache/flink/blob/c6997c97c575d334679915c328792b8a3067cfb5/flink-core/src/main/java/org/apache/flink/util/ExecutorUtils.java#L42]).
was:
{{ExecutorServiceResource}] and {{ExecutorServiceExtension}}'s shutdown
mechanism doesn't include a forced shutdown. The shutdown is triggered but no
verification happens whether the threads were actually shut down.
This issue adds a graceful shutdown to the resource/extension implementation
(compare with
[ExecutorUtils.gracefulShutdown|https://github.com/apache/flink/blob/c6997c97c575d334679915c328792b8a3067cfb5/flink-core/src/main/java/org/apache/flink/util/ExecutorUtils.java#L42]).
> ExecutorServiceResource and ExecutorServiceExtension's shutdown mechanism
> doesn't include a forced shutdown
> -----------------------------------------------------------------------------------------------------------
>
> Key: FLINK-32039
> URL: https://issues.apache.org/jira/browse/FLINK-32039
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Coordination
> Affects Versions: 1.17.0, 1.16.1, 1.18.0
> Reporter: Matthias Pohl
> Priority: Minor
>
> {{ExecutorServiceResource}} and {{ExecutorServiceExtension}}'s shutdown
> mechanism doesn't include a forced shutdown. The shutdown is triggered but no
> verification happens whether the threads were actually shut down.
> This issue adds a graceful shutdown to the resource/extension implementation
> (compare with
> [ExecutorUtils.gracefulShutdown|https://github.com/apache/flink/blob/c6997c97c575d334679915c328792b8a3067cfb5/flink-core/src/main/java/org/apache/flink/util/ExecutorUtils.java#L42]).
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
