Faster startup

This commit is contained in:
Andrea Cavalli 2023-09-03 01:14:18 +02:00
parent 40cd756f35
commit 7692b21e3d

View File

@ -923,6 +923,7 @@ public class LLLocalKeyValueDatabase extends Backuppable implements LLKeyValueDa
);
options.setDbPaths(paths);
options.setMaxOpenFiles(databaseOptions.maxOpenFiles().orElse(-1));
options.setMaxFileOpeningThreads(Runtime.getRuntime().availableProcessors());
if (databaseOptions.spinning()) {
// https://nightlies.apache.org/flink/flink-docs-release-1.3/api/java/org/apache/flink/contrib/streaming/state/PredefinedOptions.html
options.setUseFsync(false);