(incubator-streampark) branch dev-2.1.3 updated: [Improve] sync dev branch #3568

[benjobs]

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

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


The following commit(s) were added to refs/heads/dev-2.1.3 by this push:
     new 003c8884b [Improve] sync dev branch #3568
003c8884b is described below

commit 003c8884b05ccc2ce799ca90809059910b00e34d
Author: benjobs <benj...@gmail.com>
AuthorDate: Fri Feb 23 22:39:04 2024 +0800

    [Improve] sync dev branch #3568
---
 .../org/apache/streampark/flink/proxy/FlinkShimsProxy.scala    | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git 
a/streampark-flink/streampark-flink-proxy/src/main/scala/org/apache/streampark/flink/proxy/FlinkShimsProxy.scala
 
b/streampark-flink/streampark-flink-proxy/src/main/scala/org/apache/streampark/flink/proxy/FlinkShimsProxy.scala
index 0307c125f..3cf8ae250 100644
--- 
a/streampark-flink/streampark-flink-proxy/src/main/scala/org/apache/streampark/flink/proxy/FlinkShimsProxy.scala
+++ 
b/streampark-flink/streampark-flink-proxy/src/main/scala/org/apache/streampark/flink/proxy/FlinkShimsProxy.scala
@@ -162,7 +162,15 @@ object FlinkShimsProxy extends Logger {
     SHIMS_CLASS_LOADER_CACHE.getOrElseUpdate(
       s"${flinkVersion.fullVersion}", {
         // 1) flink/lib
-        val libURL = getFlinkHomeLib(flinkVersion.flinkHome, "lib", 
!_.getName.startsWith("log4j"))
+        val libURL = getFlinkHomeLib(
+          flinkVersion.flinkHome,
+          "lib",
+          file => {
+            val name = file.getName.toLowerCase
+            name.endsWith(".jar") && !name.startsWith("log4j")
+          }
+        )
+
         val shimsUrls = ListBuffer[URL](libURL: _*)
 
         // 2) add all shims jar