[
https://issues.apache.org/jira/browse/FLINK-36407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergei Morozov updated FLINK-36407:
-----------------------------------
Description:
The {{SchemaRegistry}} class exclusively uses an {{ExecutorService}} referenced
by the {{coordinatorExecutor}} field, but when the schema registry closes, the
service remains running. As a result, a program running a Flink CDC pipeline
never terminates.
For some reason, it's not reproducible with the existing integration tests but
is reproducible with the attached program.
Once {{execution.execute()}} returns, it prints the following and never
terminates.
{quote}
Thread[schema-evolution-coordinator,5,main] is still running
{quote}
was:
The {{SchemaRegistry}} class exclusively uses an {{ExecutorService}} referenced
by the {{coordinatorExecutor}} field, but when the schema registry closes, the
service remains running. As a result, a program running a Flink CDC pipeline
never terminates.
For some reason, it's not reproducible with the existing integration tests but
is reproducible with the attached program.
> SchemaRegistry doesn't shutdown its underlying ExecutorService upon closing
> ---------------------------------------------------------------------------
>
> Key: FLINK-36407
> URL: https://issues.apache.org/jira/browse/FLINK-36407
> Project: Flink
> Issue Type: Bug
> Components: Flink CDC
> Affects Versions: cdc-3.2.0
> Reporter: Sergei Morozov
> Priority: Minor
>
> The {{SchemaRegistry}} class exclusively uses an {{ExecutorService}}
> referenced by the {{coordinatorExecutor}} field, but when the schema registry
> closes, the service remains running. As a result, a program running a Flink
> CDC pipeline never terminates.
> For some reason, it's not reproducible with the existing integration tests
> but is reproducible with the attached program.
> Once {{execution.execute()}} returns, it prints the following and never
> terminates.
> {quote}
> Thread[schema-evolution-coordinator,5,main] is still running
> {quote}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
