From bdb1a78fcff624a5398a52363c2ce2f28f509213 Mon Sep 17 00:00:00 2001 From: Leonard Xu Date: Wed, 10 Aug 2022 22:50:40 +0800 Subject: [PATCH] [mysql][polardb-x] Fix the license files and tests --- .../connectors/mysql/source/MySqlSourceTestBase.java | 8 ++++++++ .../mysql/table/MysqlConnectorCharsetITCase.java | 12 +++++------- .../connectors/oracle/util/OracleJdbcUrlUtils.java | 12 +++++------- 3 files changed, 18 insertions(+), 14 deletions(-) diff --git a/flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/mysql/source/MySqlSourceTestBase.java b/flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/mysql/source/MySqlSourceTestBase.java index 82f13f82eb3..64e9b7423d5 100644 --- a/flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/mysql/source/MySqlSourceTestBase.java +++ b/flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/mysql/source/MySqlSourceTestBase.java @@ -23,6 +23,7 @@ import com.ververica.cdc.connectors.mysql.testutils.MySqlContainer; import com.ververica.cdc.connectors.mysql.testutils.MySqlVersion; +import org.junit.AfterClass; import org.junit.BeforeClass; import org.junit.Rule; import org.slf4j.Logger; @@ -63,6 +64,13 @@ public static void startContainers() { LOG.info("Containers are started."); } + @AfterClass + public static void stopContainers() { + LOG.info("Starting containers..."); + MYSQL_CONTAINER.stop(); + LOG.info("Containers are stopped."); + } + protected static MySqlContainer createMySqlContainer(MySqlVersion version) { return (MySqlContainer) new MySqlContainer(version) diff --git a/flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/mysql/table/MysqlConnectorCharsetITCase.java b/flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/mysql/table/MysqlConnectorCharsetITCase.java index 627d1ca8808..67c528e728c 100644 --- a/flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/mysql/table/MysqlConnectorCharsetITCase.java +++ b/flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/mysql/table/MysqlConnectorCharsetITCase.java @@ -1,11 +1,9 @@ /* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at + * Copyright 2022 Ververica Inc. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * diff --git a/flink-connector-oracle-cdc/src/main/java/com/ververica/cdc/connectors/oracle/util/OracleJdbcUrlUtils.java b/flink-connector-oracle-cdc/src/main/java/com/ververica/cdc/connectors/oracle/util/OracleJdbcUrlUtils.java index 2d60bc26028..7f075c9a20b 100644 --- a/flink-connector-oracle-cdc/src/main/java/com/ververica/cdc/connectors/oracle/util/OracleJdbcUrlUtils.java +++ b/flink-connector-oracle-cdc/src/main/java/com/ververica/cdc/connectors/oracle/util/OracleJdbcUrlUtils.java @@ -1,11 +1,9 @@ /* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at + * Copyright 2022 Ververica Inc. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 *