You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by we...@apache.org on 2022/05/07 11:52:48 UTC
[incubator-seatunnel] branch dev updated: [Bug] [seatunnel-core-spark] plugin jars can't be added correctly in SparkStarter (#1819)
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 <ch...@me.com>
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());
}
}