Skip to content

Commit 7c28fd9

Browse files
author
xiezhineng
committed
Fix the missing dependency on the transform JAR in the Spark engine.
1 parent 8617014 commit 7c28fd9

File tree

1 file changed

+6
-0
lines changed
  • seatunnel-core/seatunnel-spark-starter/seatunnel-spark-starter-common/src/main/java/org/apache/seatunnel/core/starter/spark

1 file changed

+6
-0
lines changed

seatunnel-core/seatunnel-spark-starter/seatunnel-spark-starter-common/src/main/java/org/apache/seatunnel/core/starter/spark/SparkStarter.java

+6
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717

1818
package org.apache.seatunnel.core.starter.spark;
1919

20+
import org.apache.seatunnel.plugin.discovery.seatunnel.SeaTunnelTransformPluginDiscovery;
2021
import org.apache.seatunnel.shade.com.typesafe.config.Config;
2122

2223
import org.apache.seatunnel.api.common.PluginIdentifier;
@@ -151,12 +152,17 @@ private List<Path> getConnectorJarDependencies() {
151152
new SeaTunnelSourcePluginDiscovery();
152153
SeaTunnelSinkPluginDiscovery seaTunnelSinkPluginDiscovery =
153154
new SeaTunnelSinkPluginDiscovery();
155+
SeaTunnelTransformPluginDiscovery seaTunnelTransformPluginDiscovery =
156+
new SeaTunnelTransformPluginDiscovery();
154157
pluginJars.addAll(
155158
seaTunnelSourcePluginDiscovery.getPluginJarPaths(
156159
getPluginIdentifiers(config, PluginType.SOURCE)));
157160
pluginJars.addAll(
158161
seaTunnelSinkPluginDiscovery.getPluginJarPaths(
159162
getPluginIdentifiers(config, PluginType.SINK)));
163+
pluginJars.addAll(
164+
seaTunnelTransformPluginDiscovery.getPluginJarPaths(
165+
getPluginIdentifiers(config, PluginType.TRANSFORM)));
160166
return pluginJars.stream()
161167
.map(url -> new File(url.getPath()).toPath())
162168
.collect(Collectors.toList());

0 commit comments

Comments
 (0)