[INLONG-9112][Agent] Add task and instance profile

justinwwhuang · Oct 26, 2023 · 6b3e80a · 6b3e80a
1 parent 116ccdd
commit 6b3e80a
Showing 1 changed file with 2 additions and 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
@@ -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) {