This is an automated email from the ASF dual-hosted git repository. gongzhongqiang pushed a commit to branch dev-resp in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
commit 091a6327d65f15ad01e7239992b032e20814bb91 Author: gongzhongqiang <[email protected]> AuthorDate: Tue Jul 2 20:12:12 2024 +0800 fix code --- .../console/core/bean/ResponseResult.java | 27 ---------------------- .../core/controller/FlinkClusterController.java | 1 - .../console/core/controller/SettingController.java | 1 - .../console/core/service/FlinkClusterService.java | 1 - .../console/core/service/SettingService.java | 1 - .../console/core/service/YarnQueueService.java | 1 - .../core/service/impl/FlinkClusterServiceImpl.java | 1 - .../core/service/impl/SettingServiceImpl.java | 1 - .../core/service/impl/YarnQueueServiceImpl.java | 1 - .../console/core/service/SettingServiceTest.java | 1 - .../console/core/service/YarnQueueServiceTest.java | 1 - 11 files changed, 37 deletions(-) diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/ResponseResult.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/ResponseResult.java deleted file mode 100644 index 86ea14e63..000000000 --- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/bean/ResponseResult.java +++ /dev/null @@ -1,27 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.streampark.console.core.bean; - -import lombok.Data; - -@Data -public class ResponseResult<T> { - private int status; - private String msg; - private T result; -} diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkClusterController.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkClusterController.java index dd796437d..0700fc52f 100644 --- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkClusterController.java +++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkClusterController.java @@ -20,7 +20,6 @@ package org.apache.streampark.console.core.controller; import org.apache.streampark.common.enums.ClusterState; import org.apache.streampark.console.base.domain.RestResponse; import org.apache.streampark.console.base.exception.InternalException; -import org.apache.streampark.console.core.bean.ResponseResult; import org.apache.streampark.console.core.entity.FlinkCluster; import org.apache.streampark.console.core.service.FlinkClusterService; import org.apache.streampark.console.core.service.ServiceHelper; diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SettingController.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SettingController.java index 988f46d62..02392111a 100644 --- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SettingController.java +++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SettingController.java @@ -20,7 +20,6 @@ package org.apache.streampark.console.core.controller; import org.apache.streampark.common.util.HadoopUtils; import org.apache.streampark.console.base.domain.RestResponse; import org.apache.streampark.console.core.bean.DockerConfig; -import org.apache.streampark.console.core.bean.ResponseResult; import org.apache.streampark.console.core.bean.SenderEmail; import org.apache.streampark.console.core.entity.Setting; import org.apache.streampark.console.core.service.SettingService; diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/FlinkClusterService.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/FlinkClusterService.java index ba24b5809..55e6484a9 100644 --- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/FlinkClusterService.java +++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/FlinkClusterService.java @@ -19,7 +19,6 @@ package org.apache.streampark.console.core.service; import org.apache.streampark.common.enums.ClusterState; import org.apache.streampark.common.enums.FlinkExecutionMode; -import org.apache.streampark.console.core.bean.ResponseResult; import org.apache.streampark.console.core.entity.FlinkCluster; import com.baomidou.mybatisplus.extension.service.IService; diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/SettingService.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/SettingService.java index 4be5c391a..405caab7e 100644 --- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/SettingService.java +++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/SettingService.java @@ -19,7 +19,6 @@ package org.apache.streampark.console.core.service; import org.apache.streampark.console.core.bean.DockerConfig; import org.apache.streampark.console.core.bean.MavenConfig; -import org.apache.streampark.console.core.bean.ResponseResult; import org.apache.streampark.console.core.bean.SenderEmail; import org.apache.streampark.console.core.entity.Setting; diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/YarnQueueService.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/YarnQueueService.java index b44111bb9..32fa4e8b1 100644 --- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/YarnQueueService.java +++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/YarnQueueService.java @@ -20,7 +20,6 @@ package org.apache.streampark.console.core.service; import org.apache.streampark.common.enums.FlinkExecutionMode; import org.apache.streampark.common.enums.SparkExecutionMode; import org.apache.streampark.console.base.domain.RestRequest; -import org.apache.streampark.console.core.bean.ResponseResult; import org.apache.streampark.console.core.entity.YarnQueue; import com.baomidou.mybatisplus.core.metadata.IPage; diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java index 195e9902b..72f1b2dd4 100644 --- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java +++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java @@ -22,7 +22,6 @@ import org.apache.streampark.common.enums.FlinkExecutionMode; import org.apache.streampark.common.util.YarnUtils; import org.apache.streampark.console.base.exception.ApiAlertException; import org.apache.streampark.console.base.exception.ApiDetailException; -import org.apache.streampark.console.core.bean.ResponseResult; import org.apache.streampark.console.core.entity.FlinkCluster; import org.apache.streampark.console.core.mapper.FlinkClusterMapper; import org.apache.streampark.console.core.service.FlinkClusterService; diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SettingServiceImpl.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SettingServiceImpl.java index a8a776525..3d1e6c151 100644 --- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SettingServiceImpl.java +++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SettingServiceImpl.java @@ -19,7 +19,6 @@ package org.apache.streampark.console.core.service.impl; import org.apache.streampark.console.core.bean.DockerConfig; import org.apache.streampark.console.core.bean.MavenConfig; -import org.apache.streampark.console.core.bean.ResponseResult; import org.apache.streampark.console.core.bean.SenderEmail; import org.apache.streampark.console.core.entity.Setting; import org.apache.streampark.console.core.mapper.SettingMapper; diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/YarnQueueServiceImpl.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/YarnQueueServiceImpl.java index 66235eab6..5caa4f164 100644 --- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/YarnQueueServiceImpl.java +++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/YarnQueueServiceImpl.java @@ -23,7 +23,6 @@ import org.apache.streampark.common.util.AssertUtils; import org.apache.streampark.console.base.domain.RestRequest; import org.apache.streampark.console.base.exception.ApiAlertException; import org.apache.streampark.console.base.mybatis.pager.MybatisPager; -import org.apache.streampark.console.core.bean.ResponseResult; import org.apache.streampark.console.core.entity.Application; import org.apache.streampark.console.core.entity.FlinkCluster; import org.apache.streampark.console.core.entity.YarnQueue; diff --git a/streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/core/service/SettingServiceTest.java b/streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/core/service/SettingServiceTest.java index eb744fe07..eaccbd817 100644 --- a/streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/core/service/SettingServiceTest.java +++ b/streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/core/service/SettingServiceTest.java @@ -19,7 +19,6 @@ package org.apache.streampark.console.core.service; import org.apache.streampark.console.SpringUnitTestBase; import org.apache.streampark.console.core.bean.DockerConfig; -import org.apache.streampark.console.core.bean.ResponseResult; import org.apache.streampark.console.core.bean.SenderEmail; import org.junit.jupiter.api.Assertions; diff --git a/streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/core/service/YarnQueueServiceTest.java b/streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/core/service/YarnQueueServiceTest.java index 03dad2f81..8a9185496 100644 --- a/streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/core/service/YarnQueueServiceTest.java +++ b/streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/core/service/YarnQueueServiceTest.java @@ -21,7 +21,6 @@ import org.apache.streampark.common.enums.FlinkExecutionMode; import org.apache.streampark.console.SpringUnitTestBase; import org.apache.streampark.console.base.domain.RestRequest; import org.apache.streampark.console.base.exception.ApiAlertException; -import org.apache.streampark.console.core.bean.ResponseResult; import org.apache.streampark.console.core.entity.YarnQueue; import org.apache.streampark.console.core.service.application.ApplicationManageService; import org.apache.streampark.console.core.service.impl.YarnQueueServiceImpl;
