Skip to content

Commit

Permalink
[INLONG-11608][Manager] Fix UT
Browse files Browse the repository at this point in the history
  • Loading branch information
fuweng11 committed Dec 17, 2024
1 parent febc393 commit 490615a
Show file tree
Hide file tree
Showing 3 changed files with 19 additions and 3 deletions.
8 changes: 8 additions & 0 deletions inlong-audit/audit-store/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -115,6 +115,14 @@
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-autoconfigure</artifactId>
</exclusion>
<exclusion>
<groupId>com.sun</groupId>
<artifactId>tools</artifactId>
</exclusion>
<exclusion>
<groupId>com.sun</groupId>
<artifactId>jconsole</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
Expand Down
8 changes: 8 additions & 0 deletions inlong-manager/manager-dao/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -65,6 +65,14 @@
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-autoconfigure</artifactId>
</exclusion>
<exclusion>
<groupId>com.sun</groupId>
<artifactId>tools</artifactId>
</exclusion>
<exclusion>
<groupId>com.sun</groupId>
<artifactId>jconsole</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -315,7 +315,7 @@ private void prepareGroupId(String groupId) {
extList.add(ext1);
extList.add(ext2);
request.setExtList(extList);
groupService.save(request, "test operator");
groupService.save(request, GLOBAL_OPERATOR);
}

private void prepareStreamId(String groupId, String streamId, String topic) {
Expand All @@ -333,7 +333,7 @@ private void prepareStreamId(String groupId, String streamId, String topic) {
ext.setKeyName(ClusterSwitch.BACKUP_MQ_RESOURCE);
ext.setKeyValue("backup_" + topic);
request.setExtList(extInfos);
streamService.save(request, "test_operator");
streamService.save(request, GLOBAL_OPERATOR);
}

private void prepareCluster(String clusterName, String clusterTag) {
Expand Down Expand Up @@ -382,7 +382,7 @@ private void prepareTask(String taskName, String groupId, String clusterName, St
properties.put("delimiter", "|");
properties.put("dataType", "text");
request.setProperties(properties);
streamSinkService.save(request, TEST_CREATOR);
streamSinkService.save(request, GLOBAL_OPERATOR);
}

}

0 comments on commit 490615a

Please sign in to comment.