Skip to content

Commit 2228766

Browse files
committed
add unit test
1 parent 3917b37 commit 2228766

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -247,6 +247,7 @@ public void testUnsupportedOption() {
247247

248248
@Test
249249
public void testOptionalOption() {
250+
inventoryDatabase.createAndInitialize();
250251
Map<String, String> options = new HashMap<>();
251252
options.put(HOSTNAME.key(), MYSQL_CONTAINER.getHost());
252253
options.put(PORT.key(), String.valueOf(MYSQL_CONTAINER.getDatabasePort()));

0 commit comments

Comments
 (0)