Skip to content

Commit 3da9eeb

Browse files
committed
Address the honorable AI comments
1 parent 0d3932b commit 3da9eeb

2 files changed

Lines changed: 10 additions & 2 deletions

File tree

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlPipelineCompatibilityITCase.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,11 @@ void setup() throws Exception {
126126

127127
@AfterEach
128128
void tearDown() {
129-
testDatabase.dropDatabase();
129+
try {
130+
testDatabase.dropDatabase();
131+
} catch (IllegalStateException e) {
132+
LOG.warn("Failed to drop test database during teardown.", e);
133+
}
130134
if (mySqlContainer != null) {
131135
LOG.info("Stopping container for MySQL {}...", version.getVersion());
132136
mySqlContainer.stop();

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/table/MySqlCompatibilityITCase.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -121,7 +121,11 @@ void setup() throws Exception {
121121

122122
@AfterEach
123123
void tearDown() {
124-
testDatabase.dropDatabase();
124+
try {
125+
testDatabase.dropDatabase();
126+
} catch (IllegalStateException e) {
127+
LOG.warn("Failed to drop test database during teardown.", e);
128+
}
125129
if (mySqlContainer != null) {
126130
LOG.info("Stopping container for MySQL {}...", version.getVersion());
127131
mySqlContainer.stop();

0 commit comments

Comments
 (0)