[
https://issues.apache.org/jira/browse/FLINK-36407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897082#comment-17897082
]
Leonard Xu edited comment on FLINK-36407 at 11/19/24 3:47 AM:
--------------------------------------------------------------
master(3.3-SNAPSHOT) : e15bf6f04a31fbbf3ebeb4c3cb891f309df29d3c
3.2: 329968f2e86ffcbb02a5c931e9e6e7119aa8b064
was (Author: ruanhang1993):
master(3.3-SNAPSHOT) : e15bf6f04a31fbbf3ebeb4c3cb891f309df29d3c
> 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
> Assignee: Sergei Morozov
> Priority: Minor
> Labels: pull-request-available
> Fix For: cdc-3.3.0, cdc-3.2.1
>
> Attachments: Flink36407Reproducer.java
>
>
> 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)
