This is an automated email from the ASF dual-hosted git repository.
wenjun pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 63103c47 [Bug] [seatunnel-core-spark] plugin jars can't be added
correctly in SparkStarter (#1819)
63103c47 is described below
commit 63103c47bb11b1ec3bc4772afa4981c87a343839
Author: huhu <[email protected]>
AuthorDate: Sat May 7 19:52:43 2022 +0800
[Bug] [seatunnel-core-spark] plugin jars can't be added correctly in
SparkStarter (#1819)
---
.../src/main/java/org/apache/seatunnel/core/spark/SparkStarter.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/seatunnel-core/seatunnel-core-spark/src/main/java/org/apache/seatunnel/core/spark/SparkStarter.java
b/seatunnel-core/seatunnel-core-spark/src/main/java/org/apache/seatunnel/core/spark/SparkStarter.java
index fd7e12d2..2f7ca546 100644
---
a/seatunnel-core/seatunnel-core-spark/src/main/java/org/apache/seatunnel/core/spark/SparkStarter.java
+++
b/seatunnel-core/seatunnel-core-spark/src/main/java/org/apache/seatunnel/core/spark/SparkStarter.java
@@ -195,7 +195,7 @@ public class SparkStarter implements Starter {
return stream
.filter(it -> pluginRootDir.relativize(it).getNameCount()
== PLUGIN_LIB_DIR_DEPTH)
.filter(it -> it.getParent().endsWith("lib"))
- .filter(it -> it.getFileName().endsWith("jar"))
+ .filter(it -> it.getFileName().toString().endsWith("jar"))
.collect(Collectors.toList());
}
}