[INLONG-9475][Manager] Fix error

apache · Dec 18, 2023 · 3f12eed · 3f12eed
1 parent 10a05a2
commit 3f12eed
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 0 deletions.
diff --git a/...er-client/src/test/java/org/apache/inlong/manager/client/api/inner/ClientFactoryTest.java b/...er-client/src/test/java/org/apache/inlong/manager/client/api/inner/ClientFactoryTest.java
@@ -236,6 +236,7 @@ void testListGroup4BinlogSource() {
                                                 .inlongGroupId("1")
                                                 .inlongStreamId("2")
                                                 .sourceType(SourceType.MYSQL_BINLOG)
+                                                .hostname("127.0.0.1")
                                                 .status(1)
                                                 .user("root")
                                                 .password("pwd")
@@ -560,6 +561,7 @@ void testListStream4AllSink() {
                 MySQLBinlogSource.builder()
                         .id(2)
                         .sourceType(SourceType.MYSQL_BINLOG)
+                        .hostname("127.0.0.1")
                         .user("user")
                         .password("pwd")
                         .build(),

diff --git a/...r-service/src/test/java/org/apache/inlong/manager/service/core/impl/AgentServiceTest.java b/...r-service/src/test/java/org/apache/inlong/manager/service/core/impl/AgentServiceTest.java
@@ -105,6 +105,7 @@ public Integer saveSource() {
         sourceInfo.setInlongStreamId(GLOBAL_STREAM_ID);
         sourceInfo.setSourceType(SourceType.MYSQL_BINLOG);
         sourceInfo.setSourceName("binlog_source_in_agent_service_test");
+        sourceInfo.setHostname("127.0.0.1");
         return sourceService.save(sourceInfo, GLOBAL_OPERATOR);
     }
 

diff --git a/...rvice/src/test/java/org/apache/inlong/manager/service/source/StreamSourceServiceTest.java b/...rvice/src/test/java/org/apache/inlong/manager/service/source/StreamSourceServiceTest.java
@@ -54,6 +54,7 @@ public Integer saveSource() {
         String sourceName = "stream_source_service_test";
         sourceInfo.setSourceName(sourceName);
         sourceInfo.setSourceType(SourceType.MYSQL_BINLOG);
+        sourceInfo.setHostname("127.0.0.1");
         Map<String, Object> properties = Maps.newLinkedHashMap();
         properties.put("append-mode", "true");
         sourceInfo.setProperties(properties);