[hotfix][cdc-connector][mongodb] Fix LegacyMongoDBSourceExampleTest c…

…annot run
apache · Aug 19, 2024 · 6fa0852 · 6fa0852
1 parent d6b687b
commit 6fa0852
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/...src/test/java/org/apache/flink/cdc/connectors/mongodb/LegacyMongoDBSourceExampleTest.java b/...src/test/java/org/apache/flink/cdc/connectors/mongodb/LegacyMongoDBSourceExampleTest.java
@@ -26,19 +26,18 @@
 
 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 {
 
     @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)