From 6b3e80a348ffcb7cf85a93044e6b151607d80c29 Mon Sep 17 00:00:00 2001 From: wenweihuang Date: Wed, 25 Oct 2023 20:11:04 +0800 Subject: [PATCH] [INLONG-9112][Agent] Add task and instance profile --- .../main/java/org/apache/inlong/agent/pojo/TaskProfileDto.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/pojo/TaskProfileDto.java b/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/pojo/TaskProfileDto.java index 275e19f3b38..964ac1cf029 100644 --- a/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/pojo/TaskProfileDto.java +++ b/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/pojo/TaskProfileDto.java @@ -32,6 +32,7 @@ import static org.apache.inlong.agent.constant.FetcherConstants.AGENT_MANAGER_VIP_HTTP_HOST; import static org.apache.inlong.agent.constant.FetcherConstants.AGENT_MANAGER_VIP_HTTP_PORT; import static org.apache.inlong.agent.constant.TaskConstants.SYNC_SEND_OPEN; +import static org.apache.inlong.common.enums.DataReportTypeEnum.NORMAL_SEND_TO_DATAPROXY; @Data public class TaskProfileDto { @@ -411,7 +412,7 @@ public static TaskProfile convertToTaskProfile(DataConfig dataConfig) { task.setState(dataConfig.getState()); // set sink type - if (dataConfig.getDataReportType() == 0) { + if (dataConfig.getDataReportType() == NORMAL_SEND_TO_DATAPROXY.ordinal()) { task.setSink(FILE_DATAPROXY_SINK); task.setProxySend(false); } else if (dataConfig.getDataReportType() == 1) {