You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by he...@apache.org on 2022/04/08 10:55:59 UTC
[incubator-inlong] branch master updated: [INLONG-3580][Manager] Remove agentIp in source request (#3581)
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 <48...@users.noreply.github.com>
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;