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());
         }
     }