This is an automated email from the ASF dual-hosted git repository.
healchow pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git
The following commit(s) were added to refs/heads/master by this push:
new 4a0565fca [INLONG-3580][Manager] Remove agentIp in source request
(#3581)
4a0565fca is described below
commit 4a0565fca5a7b3136b8eea88c8e4b4ecf7f85312
Author: kipshi <[email protected]>
AuthorDate: Fri Apr 8 18:55:51 2022 +0800
[INLONG-3580][Manager] Remove agentIp in source request (#3581)
---
.../inlong/manager/client/api/util/InlongStreamSourceTransfer.java | 1 -
.../org/apache/inlong/manager/common/pojo/source/SourceRequest.java | 3 ---
2 files changed, 4 deletions(-)
diff --git
a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/InlongStreamSourceTransfer.java
b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/InlongStreamSourceTransfer.java
index 93f513037..ef2e4e564 100644
---
a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/InlongStreamSourceTransfer.java
+++
b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/InlongStreamSourceTransfer.java
@@ -216,7 +216,6 @@ public class InlongStreamSourceTransfer {
sourceRequest.setInlongGroupId(stream.getInlongGroupId());
sourceRequest.setInlongStreamId(stream.getInlongStreamId());
sourceRequest.setSourceType(kafkaSource.getSourceType().getType());
- sourceRequest.setAgentIp(kafkaSource.getAgentIp());
sourceRequest.setBootstrapServers(kafkaSource.getBootstrapServers());
sourceRequest.setTopic(kafkaSource.getTopic());
sourceRequest.setRecordSpeedLimit(kafkaSource.getRecordSpeedLimit());
diff --git
a/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/source/SourceRequest.java
b/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/source/SourceRequest.java
index f1a55ca74..6249a266c 100644
---
a/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/source/SourceRequest.java
+++
b/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/source/SourceRequest.java
@@ -51,9 +51,6 @@ public class SourceRequest {
@ApiModelProperty("Source name, unique in one stream")
private String sourceName;
- @ApiModelProperty("Ip of the agent running the task")
- private String agentIp;
-
@ApiModelProperty("Mac uuid of the agent running the task")
private String uuid;
