This is an automated email from the ASF dual-hosted git repository.
renqs pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/master by this push:
new 5284df571 [FLINK-36023][cdc-composer] Flink CDC K8S Native Application
Mode add wrong jar url (#3523)
5284df571 is described below
commit 5284df571feb91354248bf0ffac184b89d9db30c
Author: Hongshun Wang <[email protected]>
AuthorDate: Mon Aug 12 11:23:23 2024 +0800
[FLINK-36023][cdc-composer] Flink CDC K8S Native Application Mode add wrong
jar url (#3523)
---
.../org/apache/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 1fd9e1692..e2d8ac544 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
@@ -95,9 +95,10 @@ public class FactoryDiscoveryUtils {
try {
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()))) {
