You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by le...@apache.org on 2024/03/18 10:11:57 UTC
(flink-cdc) branch master updated: [FLINK-34715][cdc][cdc-connector][mysql] Correctly close BinlogSplitReader in MySQL UTCase
This is an automated email from the ASF dual-hosted git repository.
leonard 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 14b81dc6e [FLINK-34715][cdc][cdc-connector][mysql] Correctly close BinlogSplitReader in MySQL UTCase
14b81dc6e is described below
commit 14b81dc6ec804bd516005a177aea00be75df3cc2
Author: Xin Gong <ge...@gmail.com>
AuthorDate: Mon Mar 18 18:11:52 2024 +0800
[FLINK-34715][cdc][cdc-connector][mysql] Correctly close BinlogSplitReader in MySQL UTCase
This closes #3161.
---
.../cdc/connectors/mysql/debezium/reader/BinlogSplitReaderTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/BinlogSplitReaderTest.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/BinlogSplitReaderTest.java
index 90b30d564..0d407f9c5 100644
--- a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/BinlogSplitReaderTest.java
+++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/BinlogSplitReaderTest.java
@@ -987,8 +987,8 @@ public class BinlogSplitReaderTest extends MySqlSourceTestBase {
}
binlogReader.close();
- assertNotNull(snapshotSplitReader.getExecutorService());
- assertTrue(snapshotSplitReader.getExecutorService().isTerminated());
+ assertNotNull(binlogReader.getExecutorService());
+ assertTrue(binlogReader.getExecutorService().isTerminated());
return actual;
}