[BUG][FLINK-DEPEND]Fix flink lib to exclude dependencies that do not …

…end in.jar (#3568) * [fix][bug]Fix flink lib to exclude dependencies that do not end in.jar to avoid conflicts * fix code style
apache · Feb 20, 2024 · caf4cd7 · caf4cd7
1 parent 6f480a7
commit caf4cd7
Showing 1 changed file with 4 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
@@ -165,7 +165,10 @@ 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 => (!file.getName.startsWith("log4j") && file.getName.endsWith(".jar")))
         val shimsUrls = ListBuffer[URL](libURL: _*)
 
         // 2) add all shims jar