You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by go...@apache.org on 2024/08/25 05:51:27 UTC
(flink-cdc) branch master updated: [hotfix][cdc-connector][mongodb] Fix LegacyMongoDBSourceExampleTest cannot run (#3555)
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 <ji...@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)