Sergei Morozov created FLINK-36407:
--------------------------------------
Summary: 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
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.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
