Skip to content

Commit 26eb6a9

Browse files
authored
[hotfix][cdc][build] Include cdc-common module when shaded for module flink-sql-connector-mysql-cdc
1 parent 1dc201f commit 26eb6a9

File tree

2 files changed

+3
-0
lines changed

2 files changed

+3
-0
lines changed

flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-mysql-cdc/pom.xml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -57,6 +57,7 @@ limitations under the License.
5757
<include>io.debezium:debezium-core</include>
5858
<include>io.debezium:debezium-ddl-parser</include>
5959
<include>io.debezium:debezium-connector-mysql</include>
60+
<include>com.ververica:flink-cdc-common</include>
6061
<include>com.ververica:flink-connector-debezium</include>
6162
<include>com.ververica:flink-connector-mysql-cdc</include>
6263
<include>org.antlr:antlr4-runtime</include>

flink-cdc-e2e-tests/flink-cdc-source-e2e-tests/src/test/java/org/apache/flink/cdc/connectors/tests/MySqlE2eITCase.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -119,6 +119,8 @@ public void testMySqlCDC() throws Exception {
119119
"UPDATE products_source SET description='new water resistent white wind breaker', weight='0.5' WHERE id=110;");
120120
stat.execute("UPDATE products_source SET weight='5.17' WHERE id=111;");
121121
stat.execute("DELETE FROM products_source WHERE id=111;");
122+
// add schema change event in the last.
123+
stat.execute("CREATE TABLE new_table (id int, age int);");
122124
} catch (SQLException e) {
123125
LOG.error("Update table for CDC failed.", e);
124126
throw e;

0 commit comments

Comments
 (0)