tool
/
starrocks
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[BugFix] fix paimon jni scanner (#60271) 

Signed-off-by: yan zhang <dirtysalt1987@gmail.com>
This commit is contained in:
yan zhang 2025-06-25 13:34:12 +08:00 committed by GitHub
parent 2ae06f73fb
commit 38820e9c8f
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
java-extensions/paimon-reader/src/main/java/com/starrocks/paimon/reader/PaimonSplitScannerFactory.java
View File

@ -17,24 +17,11 @@ package com.starrocks.paimon.reader;
import com.starrocks.jni.connector.ScannerFactory; import com.starrocks.jni.connector.ScannerFactory;
import com.starrocks.jni.connector.ScannerHelper; import com.starrocks.jni.connector.ScannerHelper;
import java.io.File;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Objects;
public class PaimonSplitScannerFactory implements ScannerFactory { public class PaimonSplitScannerFactory implements ScannerFactory {
static ClassLoader classLoader; static ClassLoader classLoader;
static { static {
String basePath = System.getenv("STARROCKS_HOME"); classLoader = ScannerHelper.createModuleClassLoader("paimon-reader-lib");
List<File> preloadFiles = new ArrayList<>();
preloadFiles.add(new File(basePath + "/lib/jni-packages/starrocks-hadoop-ext.jar"));
File dir = new File(basePath + "/lib/paimon-reader-lib");
preloadFiles.addAll(Arrays.asList(Objects.requireNonNull(dir.listFiles())));
dir = new File(basePath + "/lib/common-runtime-lib");
preloadFiles.addAll(Arrays.asList(Objects.requireNonNull(dir.listFiles())));
classLoader = ScannerHelper.createChildFirstClassLoader(preloadFiles, "paimon scanner");
} }
/** /**