database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](multi-catalog)fix jdbc loader (#22814)

Browse Source
This commit is contained in:
slothever
2023-08-11 14:36:19 +08:00
committed by GitHub
parent 94a7b44540
commit 209f36f1bf
6 changed files with 11 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
fe/be-java-extensions/java-common/src/main/java/org/apache/doris/common/classloader/JniScannerClassLoader.java
View File

@ -25,8 +25,8 @@ public class JniScannerClassLoader extends URLClassLoader {
private final String scannerName;
public JniScannerClassLoader(String scannerName, List<URL> urls) {
super(urls.toArray(new URL[0]), ClassLoader.getSystemClassLoader());
public JniScannerClassLoader(String scannerName, List<URL> urls, ClassLoader parent) {
super(urls.toArray(new URL[0]), parent);
this.scannerName = scannerName;
}

3
fe/be-java-extensions/java-common/src/main/java/org/apache/doris/common/classloader/ScannerLoader.java
View File

@ -52,7 +52,8 @@ public class ScannerLoader {
File library = new File(basePath, "/lib/java_extensions/");
// TODO: add thread pool to load each scanner
listFiles(library).stream().filter(File::isDirectory).forEach(sd -> {
JniScannerClassLoader classLoader = new JniScannerClassLoader(sd.getName(), buildClassPath(sd));
JniScannerClassLoader classLoader = new JniScannerClassLoader(sd.getName(), buildClassPath(sd),
this.getClass().getClassLoader());
try (ThreadClassLoaderContext ignored = new ThreadClassLoaderContext(classLoader)) {
loadJarClassFromDir(sd, classLoader);
}