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 e854aebbc9 [Improvement-18056] Remove unused code in datasource module
(#18111)
e854aebbc9 is described below
commit e854aebbc92b10c362c0119bd923b6011a1a092f
Author: xiangzihao <[email protected]>
AuthorDate: Wed Apr 1 15:06:00 2026 +0800
[Improvement-18056] Remove unused code in datasource module (#18111)
---
.../AliyunServerlessSparkUtils.java | 41 ----------------------
.../plugin/datasource/zeppelin/ZeppelinUtils.java | 36 -------------------
2 files changed, 77 deletions(-)
diff --git
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-aliyunserverlessspark/src/main/java/org/apache/dolphinscheduler/plugin/datasource/aliyunserverlessspark/AliyunServerlessSparkUtils.java
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-aliyunserverlessspark/src/main/java/org/apache/dolphinscheduler/plugin/datasource/aliyunserverlessspark/AliyunServerlessSparkUtils.java
deleted file mode 100644
index bb53ff8b88..0000000000
---
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-aliyunserverlessspark/src/main/java/org/apache/dolphinscheduler/plugin/datasource/aliyunserverlessspark/AliyunServerlessSparkUtils.java
+++ /dev/null
@@ -1,41 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.dolphinscheduler.plugin.datasource.aliyunserverlessspark;
-
-import
org.apache.dolphinscheduler.plugin.datasource.aliyunserverlessspark.param.AliyunServerlessSparkConnectionParam;
-
-import com.aliyun.emr_serverless_spark20230808.Client;
-import com.aliyun.teaopenapi.models.Config;
-
-public class AliyunServerlessSparkUtils {
-
- private AliyunServerlessSparkUtils() {
- throw new IllegalStateException("Utility class");
- }
-
- public static Client
getAliyunServerlessSparkClient(AliyunServerlessSparkConnectionParam
connectionParam) throws Exception {
- String endpoint =
-
String.format(AliyunServerlessSparkConstants.ENDPOINT_TEMPLATE,
connectionParam.getRegionId());
- Config config = new Config()
- .setEndpoint(endpoint)
- .setAccessKeyId(connectionParam.getAccessKeyId())
- .setAccessKeySecret(connectionParam.getAccessKeySecret());
- return new Client(config);
- }
-
-}
diff --git
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-zeppelin/src/main/java/org/apache/dolphinscheduler/plugin/datasource/zeppelin/ZeppelinUtils.java
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-zeppelin/src/main/java/org/apache/dolphinscheduler/plugin/datasource/zeppelin/ZeppelinUtils.java
deleted file mode 100644
index 308af03d8f..0000000000
---
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-zeppelin/src/main/java/org/apache/dolphinscheduler/plugin/datasource/zeppelin/ZeppelinUtils.java
+++ /dev/null
@@ -1,36 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.dolphinscheduler.plugin.datasource.zeppelin;
-
-import
org.apache.dolphinscheduler.plugin.datasource.zeppelin.param.ZeppelinConnectionParam;
-
-import org.apache.zeppelin.client.ClientConfig;
-import org.apache.zeppelin.client.ZeppelinClient;
-
-public class ZeppelinUtils {
-
- private ZeppelinUtils() {
- throw new IllegalStateException("Utility class");
- }
-
- public static ZeppelinClient getZeppelinClient(ZeppelinConnectionParam
connectionParam) throws Exception {
- ClientConfig clientConfig = new
ClientConfig(connectionParam.getRestEndpoint());
- return new ZeppelinClient(clientConfig);
- }
-
-}
