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)