(incubator-streampark) branch dev-2.1.2 updated: [Improve] flink classpaths minor improvement

[benjobs]

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

benjobs pushed a commit to branch dev-2.1.2
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git


The following commit(s) were added to refs/heads/dev-2.1.2 by this push:
     new 5a4ca63a6 [Improve] flink classpaths minor improvement
5a4ca63a6 is described below

commit 5a4ca63a6bf98e1fe772df5ba55beabc7cdd2438
Author: benjobs <benj...@gmail.com>
AuthorDate: Sat Oct 28 09:37:31 2023 +0800

    [Improve] flink classpaths minor improvement
---
 .../apache/streampark/flink/client/trait/FlinkClientTrait.scala    | 7 ++-----
 1 file changed, 2 insertions(+), 5 deletions(-)

diff --git 
a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala
 
b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala
index 3d69c760a..3212b6451 100644
--- 
a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala
+++ 
b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala
@@ -241,11 +241,8 @@ trait FlinkClientTrait extends Logger {
     val packageProgram = PackagedProgram.newBuilder
       .setJarFile(jarFile)
       .setUserClassPaths(
-        Lists.newArrayList(
-          submitRequest.flinkVersion.flinkLib
-            .listFiles()
-            .map(_.toURI.toURL)
-            .toBuffer[URL]: _*))
+        Lists.newArrayList(submitRequest.flinkVersion.flinkLibs: _*)
+      )
       .setEntryPointClassName(
         
flinkConfig.getOptional(ApplicationConfiguration.APPLICATION_MAIN_CLASS).get())
       .setSavepointRestoreSettings(submitRequest.savepointRestoreSettings)