From d2f857ec869ce7665c1f36300ac549abba39dd8a Mon Sep 17 00:00:00 2001 From: wangxj3 <857234426@qq.com> Date: Tue, 6 Aug 2024 14:16:48 +0800 Subject: [PATCH] remove duplicate code of AliyunServerlessSparkDataSourceProcessor (#16422) --- .../param/AliyunServerlessSparkDataSourceProcessor.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-aliyunserverlessspark/src/main/java/org/apache/dolphinscheduler/plugin/datasource/aliyunserverlessspark/param/AliyunServerlessSparkDataSourceProcessor.java b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-aliyunserverlessspark/src/main/java/org/apache/dolphinscheduler/plugin/datasource/aliyunserverlessspark/param/AliyunServerlessSparkDataSourceProcessor.java index ac1905e237..2ccd62e3ee 100644 --- a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-aliyunserverlessspark/src/main/java/org/apache/dolphinscheduler/plugin/datasource/aliyunserverlessspark/param/AliyunServerlessSparkDataSourceProcessor.java +++ b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-aliyunserverlessspark/src/main/java/org/apache/dolphinscheduler/plugin/datasource/aliyunserverlessspark/param/AliyunServerlessSparkDataSourceProcessor.java @@ -49,8 +49,7 @@ public class AliyunServerlessSparkDataSourceProcessor extends AbstractDataSource AliyunServerlessSparkDataSourceParamDTO aliyunServerlessSparkDataSourceParamDTO = (AliyunServerlessSparkDataSourceParamDTO) datasourceParamDTO; if (StringUtils.isEmpty(aliyunServerlessSparkDataSourceParamDTO.getRegionId()) || - StringUtils.isEmpty(aliyunServerlessSparkDataSourceParamDTO.getAccessKeyId()) || - StringUtils.isEmpty(aliyunServerlessSparkDataSourceParamDTO.getRegionId())) { + StringUtils.isEmpty(aliyunServerlessSparkDataSourceParamDTO.getAccessKeyId())) { throw new IllegalArgumentException("spark datasource param is not valid"); } }