natas_hw
/
dolphinscheduler
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

remove debugging logs

This commit is contained in:
EricGao888 2024-05-29 15:26:30 +08:00
parent 56accb07cb
commit f8a49cc647
2 changed files with 1 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
dolphinscheduler-bom/pom.xml
View File

@ -395,8 +395,7 @@
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>${mysql-connector.version}</version>
<!-- TODO: Revert this!!!-->
<!-- <scope>test</scope>-->
<scope>test</scope>
</dependency>
<dependency>

5
dolphinscheduler-task-plugin/dolphinscheduler-task-aliyunserverlessspark/src/main/java/org/apache/dolphinscheduler/plugin/task/aliyunserverlessspark/AliyunServerlessSparkTask.java
View File

@ -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)