From 7a4391500e83d922251dfb31b1cd66ed32a3cfa1 Mon Sep 17 00:00:00 2001 From: Hongshun Wang Date: Fri, 9 Aug 2024 17:40:09 +0800 Subject: [PATCH] [FLINK-36023][cdc-composer] Hotfix: Flink CDC K8S Native Application Mode add wrong jar url. --- .../flink/cdc/composer/utils/FactoryDiscoveryUtils.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/utils/FactoryDiscoveryUtils.java b/flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/utils/FactoryDiscoveryUtils.java index 4f7649d9e4d..2699c0cc565 100644 --- a/flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/utils/FactoryDiscoveryUtils.java +++ b/flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/utils/FactoryDiscoveryUtils.java @@ -94,9 +94,10 @@ public static Optional getJarPathByIdentifier( T factory = getFactoryByIdentifier(identifier, factoryClass); URL url = factory.getClass().getProtectionDomain().getCodeSource().getLocation(); String urlString = url.toString(); - if (urlString.contains("usrlib")) { - String flinkHome = System.getenv("FLINK_HOME"); - urlString = urlString.replace("usrlib", flinkHome + "/usrlib"); + // if already in usr lib of k8s, the jar has been added into classpath.Thus, no need to + // upload jar anymore. + if (urlString.startsWith("local:///opt/flink/usrlib/")) { + return Optional.empty(); } url = new URL(urlString); if (Files.isDirectory(Paths.get(url.toURI()))) {