[FLINK-36407] Shut down coordinatorExecutor upon closing SchemaRegistry

apache · Sep 29, 2024 · 9ae27ab · 9ae27ab
1 parent 4b13c49
commit 9ae27ab
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...c/main/java/org/apache/flink/cdc/runtime/operators/schema/coordinator/SchemaRegistry.java b/...c/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();
     }