You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ru...@apache.org on 2024/11/11 06:01:59 UTC
(flink-cdc) branch master updated: [FLINK-36407][runtime] Shut down coordinatorExecutor upon closing SchemaRegistry (#3624)
This is an automated email from the ASF dual-hosted git repository.
ruanhang1993 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/master by this push:
new e15bf6f04 [FLINK-36407][runtime] Shut down coordinatorExecutor upon closing SchemaRegistry (#3624)
e15bf6f04 is described below
commit e15bf6f04a31fbbf3ebeb4c3cb891f309df29d3c
Author: Sergei Morozov <se...@decodable.co>
AuthorDate: Sun Nov 10 22:01:56 2024 -0800
[FLINK-36407][runtime] Shut down coordinatorExecutor upon closing SchemaRegistry (#3624)
---
.../flink/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 64d4fa1bc..b7223c633 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 class SchemaRegistry implements OperatorCoordinator, CoordinationRequestH
@Override
public void close() throws Exception {
LOG.info("SchemaRegistry for {} closed.", operatorName);
+ coordinatorExecutor.shutdown();
requestHandler.close();
}