remove duplicate code of AliyunServerlessSparkDataSourceProcessor (#16422)

4 months ago · d2f857ec86
1 changed files with 1 additions and 2 deletions
--- 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");
        }
    }