(flink-cdc) branch master updated: [hotfix][cdc-connector][mongodb] Fix LegacyMongoDBSourceExampleTest cannot run (#3555)

[gongzhongqiang]

This is an automated email from the ASF dual-hosted git repository.

gongzhongqiang 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 aea2b6aa9 [hotfix][cdc-connector][mongodb] Fix 
LegacyMongoDBSourceExampleTest cannot run (#3555)
aea2b6aa9 is described below

commit aea2b6aa9cb54b43c5df8c7ad97a59b4f9a8f61d
Author: Jiabao Sun <jiabao...@apache.org>
AuthorDate: Sun Aug 25 13:51:23 2024 +0800

    [hotfix][cdc-connector][mongodb] Fix LegacyMongoDBSourceExampleTest cannot 
run (#3555)
---
 .../flink/cdc/connectors/mongodb/LegacyMongoDBSourceExampleTest.java | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git 
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/test/java/org/apache/flink/cdc/connectors/mongodb/LegacyMongoDBSourceExampleTest.java
 
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/test/java/org/apache/flink/cdc/connectors/mongodb/LegacyMongoDBSourceExampleTest.java
index 7204f8d8f..479715365 100644
--- 
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/test/java/org/apache/flink/cdc/connectors/mongodb/LegacyMongoDBSourceExampleTest.java
+++ 
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/test/java/org/apache/flink/cdc/connectors/mongodb/LegacyMongoDBSourceExampleTest.java
@@ -26,7 +26,6 @@ import org.junit.Test;
 
 import static 
org.apache.flink.cdc.connectors.mongodb.LegacyMongoDBContainer.FLINK_USER;
 import static 
org.apache.flink.cdc.connectors.mongodb.LegacyMongoDBContainer.FLINK_USER_PASSWORD;
-import static 
org.apache.flink.cdc.connectors.mongodb.LegacyMongoDBTestBase.MONGODB_CONTAINER;
 
 /** Example Tests for {@link MongoDBSource}. */
 public class LegacyMongoDBSourceExampleTest extends 
LegacyMongoDBSourceTestBase {
@@ -34,11 +33,11 @@ public class LegacyMongoDBSourceExampleTest extends 
LegacyMongoDBSourceTestBase
     @Test
     @Ignore("Test ignored because it won't stop and is used for manual test")
     public void testConsumingAllEvents() throws Exception {
-        String inventory = 
SHARD.executeCommandFileInSeparateDatabase("inventory");
+        String inventory = 
ROUTER.executeCommandFileInSeparateDatabase("inventory");
 
         SourceFunction<String> sourceFunction =
                 MongoDBSource.<String>builder()
-                        .hosts(MONGODB_CONTAINER.getHostAndPort())
+                        .hosts(ROUTER.getHostAndPort())
                         .username(FLINK_USER)
                         .password(FLINK_USER_PASSWORD)
                         .databaseList(inventory)