(seatunnel) branch dev updated: [Fix][seatunnel-spark-starter] Fix when Spark submits tasks in the fo… (#10033)

[shenghang]

This is an automated email from the ASF dual-hosted git repository.

shenghang pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new b44cbf6ecb [Fix][seatunnel-spark-starter] Fix when Spark submits tasks 
in the fo… (#10033)
b44cbf6ecb is described below

commit b44cbf6ecb230c58e7d4b1b99aef7bbda28e8b73
Author: LiJie20190102 <53458004+lijie20190...@users.noreply.github.com>
AuthorDate: Sun Nov 16 21:21:11 2025 +0800

    [Fix][seatunnel-spark-starter] Fix when Spark submits tasks in the fo… 
(#10033)
    
    Co-authored-by: lijie <lij...@cmss.chinamobile.com>
---
 .../java/org/apache/seatunnel/core/starter/spark/SparkStarter.java   | 5 +++++
 .../java/org/apache/seatunnel/core/starter/spark/SparkStarter.java   | 5 +++++
 2 files changed, 10 insertions(+)

diff --git 
a/seatunnel-core/seatunnel-spark-starter/seatunnel-spark-2-starter/src/main/java/org/apache/seatunnel/core/starter/spark/SparkStarter.java
 
b/seatunnel-core/seatunnel-spark-starter/seatunnel-spark-2-starter/src/main/java/org/apache/seatunnel/core/starter/spark/SparkStarter.java
index 63fa15ebb1..f5061a3598 100644
--- 
a/seatunnel-core/seatunnel-spark-starter/seatunnel-spark-2-starter/src/main/java/org/apache/seatunnel/core/starter/spark/SparkStarter.java
+++ 
b/seatunnel-core/seatunnel-spark-starter/seatunnel-spark-2-starter/src/main/java/org/apache/seatunnel/core/starter/spark/SparkStarter.java
@@ -152,6 +152,11 @@ public class SparkStarter implements Starter {
         pluginJars.addAll(
                 seaTunnelSourcePluginDiscovery.getPluginJarAndDependencyPaths(
                         getPluginIdentifiers(config, PluginType.SOURCE)));
+        if (config.hasPath(PluginType.TRANSFORM.getType())) {
+            pluginJars.addAll(
+                    
seaTunnelSinkPluginDiscovery.getPluginJarAndDependencyPaths(
+                            getPluginIdentifiers(config, 
PluginType.TRANSFORM)));
+        }
         pluginJars.addAll(
                 seaTunnelSinkPluginDiscovery.getPluginJarAndDependencyPaths(
                         getPluginIdentifiers(config, PluginType.SINK)));
diff --git 
a/seatunnel-core/seatunnel-spark-starter/seatunnel-spark-starter-common/src/main/java/org/apache/seatunnel/core/starter/spark/SparkStarter.java
 
b/seatunnel-core/seatunnel-spark-starter/seatunnel-spark-starter-common/src/main/java/org/apache/seatunnel/core/starter/spark/SparkStarter.java
index f53c492e24..021a24d573 100644
--- 
a/seatunnel-core/seatunnel-spark-starter/seatunnel-spark-starter-common/src/main/java/org/apache/seatunnel/core/starter/spark/SparkStarter.java
+++ 
b/seatunnel-core/seatunnel-spark-starter/seatunnel-spark-starter-common/src/main/java/org/apache/seatunnel/core/starter/spark/SparkStarter.java
@@ -152,6 +152,11 @@ public class SparkStarter implements Starter {
         pluginJars.addAll(
                 seaTunnelSourcePluginDiscovery.getPluginJarAndDependencyPaths(
                         getPluginIdentifiers(config, PluginType.SOURCE)));
+        if (config.hasPath(PluginType.TRANSFORM.getType())) {
+            pluginJars.addAll(
+                    
seaTunnelSinkPluginDiscovery.getPluginJarAndDependencyPaths(
+                            getPluginIdentifiers(config, 
PluginType.TRANSFORM)));
+        }
         pluginJars.addAll(
                 seaTunnelSinkPluginDiscovery.getPluginJarAndDependencyPaths(
                         getPluginIdentifiers(config, PluginType.SINK)));