[Improve] sync dev branch #3568

apache · Feb 23, 2024 · 003c888 · 003c888
1 parent 19aa1fd
commit 003c888
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/...ampark-flink-proxy/src/main/scala/org/apache/streampark/flink/proxy/FlinkShimsProxy.scala b/...ampark-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