From 9ae27abcb9c5f45f3a0e3ff00f1c714ae1e152a6 Mon Sep 17 00:00:00 2001
From: Sergei Morozov <sergei@decodable.co>
Date: Sun, 29 Sep 2024 15:36:45 -0700
Subject: [PATCH] [FLINK-36407] Shut down coordinatorExecutor upon closing
 SchemaRegistry

---
 .../cdc/runtime/operators/schema/coordinator/SchemaRegistry.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/coordinator/SchemaRegistry.java b/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/coordinator/SchemaRegistry.java
index 64d4fa1bc8..b7223c633b 100644
--- a/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/coordinator/SchemaRegistry.java
+++ b/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/coordinator/SchemaRegistry.java
@@ -168,6 +168,7 @@ public void start() throws Exception {
     @Override
     public void close() throws Exception {
         LOG.info("SchemaRegistry for {} closed.", operatorName);
+        coordinatorExecutor.shutdown();
         requestHandler.close();
     }