From 156abc55298c3b4587f2babe33bede3c32ad6136 Mon Sep 17 00:00:00 2001 From: fuwenkai <834260992@qq.com> Date: Mon, 23 Dec 2024 11:46:47 +0800 Subject: [PATCH] [INLONG-11618][Manager] Fix code style --- .../manager/service/node/DataNodeServiceImpl.java | 7 ++++--- .../service/node/cos/COSDataNodeOperator.java | 2 -- .../service/source/cos/COSSourceOperator.java | 13 +++++++------ 3 files changed, 11 insertions(+), 11 deletions(-) diff --git a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/node/DataNodeServiceImpl.java b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/node/DataNodeServiceImpl.java index 8dc6b7f3cb..f7db3ec87e 100644 --- a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/node/DataNodeServiceImpl.java +++ b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/node/DataNodeServiceImpl.java @@ -17,9 +17,6 @@ package org.apache.inlong.manager.service.node; -import com.github.pagehelper.Page; -import com.github.pagehelper.PageHelper; -import org.apache.commons.lang3.StringUtils; import org.apache.inlong.manager.common.consts.InlongConstants; import org.apache.inlong.manager.common.enums.ErrorCodeEnum; import org.apache.inlong.manager.common.enums.TenantUserTypeEnum; @@ -34,6 +31,10 @@ import org.apache.inlong.manager.pojo.node.DataNodePageRequest; import org.apache.inlong.manager.pojo.node.DataNodeRequest; import org.apache.inlong.manager.pojo.user.UserInfo; + +import com.github.pagehelper.Page; +import com.github.pagehelper.PageHelper; +import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; diff --git a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/node/cos/COSDataNodeOperator.java b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/node/cos/COSDataNodeOperator.java index a26b384315..2e4cc594ba 100644 --- a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/node/cos/COSDataNodeOperator.java +++ b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/node/cos/COSDataNodeOperator.java @@ -31,8 +31,6 @@ import com.fasterxml.jackson.databind.ObjectMapper; import org.apache.commons.lang3.StringUtils; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; diff --git a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/cos/COSSourceOperator.java b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/cos/COSSourceOperator.java index cc361d8142..f99a6321bd 100644 --- a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/cos/COSSourceOperator.java +++ b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/cos/COSSourceOperator.java @@ -17,8 +17,6 @@ package org.apache.inlong.manager.service.source.cos; -import com.fasterxml.jackson.databind.ObjectMapper; -import org.apache.commons.lang3.StringUtils; import org.apache.inlong.manager.common.consts.DataNodeType; import org.apache.inlong.manager.common.consts.SourceType; import org.apache.inlong.manager.common.enums.ErrorCodeEnum; @@ -38,6 +36,9 @@ import org.apache.inlong.manager.pojo.source.cos.COSSourceRequest; import org.apache.inlong.manager.pojo.stream.StreamField; import org.apache.inlong.manager.service.source.AbstractSourceOperator; + +import com.fasterxml.jackson.databind.ObjectMapper; +import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; @@ -102,10 +103,10 @@ public StreamSource getFromEntity(StreamSourceEntity entity) { List dataAddTaskList = sourceMapper.selectByTaskMapId(entity.getId()); source.setDataAddTaskList(dataAddTaskList.stream().map(subEntity -> DataAddTaskDTO.builder() - .id(subEntity.getId()) - .taskMapId(entity.getId()) - .agentIp(subEntity.getAgentIp()) - .status(subEntity.getStatus()).build()) + .id(subEntity.getId()) + .taskMapId(entity.getId()) + .agentIp(subEntity.getAgentIp()) + .status(subEntity.getStatus()).build()) .collect(Collectors.toList())); return source; }