Skip to content

[Fix-18177][Task Plugin] Fix AliyunServerlessSpark plugin dependency conflicts and improve exception handling #18180

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
includetts wants to merge 12 commits into
base: dev
Choose a base branch
from
Open

[Fix-18177][Task Plugin] Fix AliyunServerlessSpark plugin dependency conflicts and improve exception handling #18180

Show file tree
Hide file tree
Changes from 3 commits
Commits
Show all changes
12 commits
Select commit Hold shift + click to select a range
a2be20b
Update dependency versions for Aliyun Spark and credentialsfix: upgra…
includetts Apr 17, 2026
9f5815f
fix: propagate exception cause in AliyunServerlessSparkTask catch blocks
includetts Apr 17, 2026
8b3f531
fix: upgrade task plugin credentials-java to 1.0.1
includetts Apr 17, 2026
8172498
Merge branch 'dev' into fix/aliyun-serverless-spark-deps-v2
includetts Apr 20, 2026
51bab54
refactor: use properties to manage dependency versions in datasource …
includetts Apr 20, 2026
bb7d918
refactor: use properties to manage dependency versions in task plugin
includetts Apr 20, 2026
7599bf4
revert: remove exception cause propagation per review feedback
includetts Apr 20, 2026
7713ad8
fix e.getMessage() and e are duplicated. You just need to keep one
includetts Apr 20, 2026
9709116
fixe getMessage() and e are duplicated. You just need to keep one.
includetts Apr 20, 2026
6b870cc
Fix exception handling in cancelJobRun method
includetts Apr 20, 2026
2d12226
Merge branch 'dev' into fix/aliyun-serverless-spark-deps-v2
SbloodyS Apr 20, 2026
9e75422
Fix formatting of exception messages in AliyunServerlessSparkTask
includetts Apr 20, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-aliyunserverlessspark/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -54,13 +54,13 @@
<dependency>
<groupId>com.aliyun</groupId>
<artifactId>emr_serverless_spark20230808</artifactId>
<version>1.0.0</version>
<version>2.4.1</version>
Comment thread
SbloodyS marked this conversation as resolved.
Outdated
</dependency>

<dependency>
<groupId>com.aliyun</groupId>
<artifactId>credentials-java</artifactId>
<version>0.3.0</version>
<version>1.0.1</version>
Comment thread
SbloodyS marked this conversation as resolved.
Outdated
</dependency>
</dependencies>

Expand Down
2 changes: 1 addition & 1 deletion dolphinscheduler-task-plugin/dolphinscheduler-task-aliyunserverlessspark/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -73,7 +73,7 @@
<dependency>
<groupId>com.aliyun</groupId>
<artifactId>credentials-java</artifactId>
<version>0.3.0</version>
<version>1.0.1</version>
Comment thread
SbloodyS marked this conversation as resolved.
Outdated
</dependency>
</dependencies>

Expand Down
6 changes: 3 additions & 3 deletions .../apache/dolphinscheduler/plugin/task/aliyunserverlessspark/AliyunServerlessSparkTask.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -118,7 +118,7 @@ public void init() {
buildAliyunServerlessSparkClient(accessKeyId, accessKeySecret, regionId, endpoint);
} catch (Exception e) {
log.error("Failed to build Aliyun-Serverless-Spark client!", e);
throw new AliyunServerlessSparkTaskException("Failed to build Aliyun-Serverless-Spark client!");
throw new AliyunServerlessSparkTaskException("Failed to build Aliyun-Serverless-Spark client! " + e.getMessage(), e);
Comment thread
SbloodyS marked this conversation as resolved.
Outdated
}

currentState = RunState.Submitted;
Expand Down Expand Up @@ -154,7 +154,7 @@ public void handle(TaskCallBack taskCallBack) throws TaskException {
return aliyunServerlessSparkClient.startJobRun(
aliyunServerlessSparkParameters.getWorkspaceId(), startJobRunRequest);
} catch (Exception e) {
throw new AliyunServerlessSparkTaskException("Failed to start job run!");
throw new AliyunServerlessSparkTaskException("Failed to start job run! " + e.getMessage(), e);
Comment thread
SbloodyS marked this conversation as resolved.
Outdated
Comment thread
SbloodyS marked this conversation as resolved.
Outdated
}
}, retryPolicy);

Expand Down Expand Up @@ -224,7 +224,7 @@ public void cancelApplication() throws TaskException {
aliyunServerlessSparkParameters.getWorkspaceId(), jobRunId,
cancelJobRunRequest);
} catch (Exception e) {
throw new AliyunServerlessSparkTaskException("Failed to cancel job run!");
throw new AliyunServerlessSparkTaskException("Failed to cancel job run! " + e.getMessage(), e);
Comment thread
SbloodyS marked this conversation as resolved.
Outdated
}
}, retryPolicy);
}
Expand Down
Loading