(dolphinscheduler) branch dev updated: remove duplicate code of AliyunServerlessSparkDataSourceProcessor (#16422)

[zihaoxiang]

This is an automated email from the ASF dual-hosted git repository.

zihaoxiang pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new d2f857ec86 remove duplicate code of 
AliyunServerlessSparkDataSourceProcessor (#16422)
d2f857ec86 is described below

commit d2f857ec869ce7665c1f36300ac549abba39dd8a
Author: wangxj3 <857234...@qq.com>
AuthorDate: Tue Aug 6 14:16:48 2024 +0800

    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");
         }
     }