diff --git a/dolphinscheduler-bom/pom.xml b/dolphinscheduler-bom/pom.xml index 4149c4cf5b..10c4f0e4a1 100644 --- a/dolphinscheduler-bom/pom.xml +++ b/dolphinscheduler-bom/pom.xml @@ -395,8 +395,7 @@ mysql mysql-connector-java ${mysql-connector.version} - - + test diff --git a/dolphinscheduler-task-plugin/dolphinscheduler-task-aliyunserverlessspark/src/main/java/org/apache/dolphinscheduler/plugin/task/aliyunserverlessspark/AliyunServerlessSparkTask.java b/dolphinscheduler-task-plugin/dolphinscheduler-task-aliyunserverlessspark/src/main/java/org/apache/dolphinscheduler/plugin/task/aliyunserverlessspark/AliyunServerlessSparkTask.java index 09832ad76d..017ce7b7cb 100644 --- a/dolphinscheduler-task-plugin/dolphinscheduler-task-aliyunserverlessspark/src/main/java/org/apache/dolphinscheduler/plugin/task/aliyunserverlessspark/AliyunServerlessSparkTask.java +++ b/dolphinscheduler-task-plugin/dolphinscheduler-task-aliyunserverlessspark/src/main/java/org/apache/dolphinscheduler/plugin/task/aliyunserverlessspark/AliyunServerlessSparkTask.java @@ -91,8 +91,6 @@ public class AliyunServerlessSparkTask extends AbstractRemoteTask { ResourceParametersHelper resourceParametersHelper = taskExecutionContext.getResourceParametersHelper(); DataSourceParameters dataSourceParameters = (DataSourceParameters) resourceParametersHelper.getResourceParameters(ResourceType.DATASOURCE, aliyunServerlessSparkParameters.getDatasource()); - log.info("[debug111] dataSourceParameters - {}", dataSourceParameters); - log.info("[debug111] aliyunServerlessSparkParameters - {}", aliyunServerlessSparkParameters); aliyunServerlessSparkConnectionParam = (AliyunServerlessSparkConnectionParam) DataSourceUtils .buildConnectionParams( DbType.valueOf(aliyunServerlessSparkParameters.getType()), @@ -184,9 +182,6 @@ public class AliyunServerlessSparkTask extends AbstractRemoteTask { private Client buildAliyunServerlessSparkClient(String accessKeyId, String accessKeySecret, String regionId) throws Exception { String endpoint = String.format("emr-serverless-spark.%s.aliyuncs.com", regionId); - log.info("[debug111] ak - {}", accessKeyId); - log.info("[debug111] sk - {}", accessKeySecret); - log.info("[debug111] region - {}", regionId); Config config = new Config() .setEndpoint(endpoint) .setAccessKeyId(accessKeyId)