From da3e7fdf33529a6b7925140d34bd342eb5e2f7c2 Mon Sep 17 00:00:00 2001
From: Andrea Cavalli <andrea@cavallium.it>
Date: Mon, 21 Mar 2022 15:22:55 +0100
Subject: [PATCH] Restore default scheduler

---
 .../dbengine/database/disk/LLLocalLuceneIndex.java          | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalLuceneIndex.java b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalLuceneIndex.java
index 1b53f24..2b62353 100644
--- a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalLuceneIndex.java
+++ b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalLuceneIndex.java
@@ -42,7 +42,6 @@ import it.cavallium.dbengine.rpc.current.data.LuceneOptions;
 import java.io.IOException;
 import java.util.ArrayList;
 import java.util.List;
-import java.util.Map;
 import java.util.Map.Entry;
 import java.util.Objects;
 import java.util.concurrent.Callable;
@@ -80,15 +79,14 @@ public class LLLocalLuceneIndex implements LLLuceneIndex {
 
 	protected static final Logger logger = LogManager.getLogger(LLLocalLuceneIndex.class);
 
+	private static final ReentrantLock shutdownLock = new ReentrantLock();
 	/**
 	 * Global lucene index scheduler.
 	 * There is only a single thread globally to not overwhelm the disk with
 	 * concurrent commits or concurrent refreshes.
 	 */
-	private static final ReentrantLock shutdownLock = new ReentrantLock();
 	private static final Scheduler luceneHeavyTasksScheduler = uninterruptibleScheduler(Schedulers.single(Schedulers.boundedElastic()));
-	private static final Scheduler bulkScheduler =  uninterruptibleScheduler(Schedulers.newBoundedElastic(
-			DEFAULT_BOUNDED_ELASTIC_SIZE, DEFAULT_BOUNDED_ELASTIC_QUEUESIZE, "bulkBoundedElastic", 60, true));
+	private static final Scheduler bulkScheduler = uninterruptibleScheduler(Schedulers.boundedElastic());
 
 	static {
 		LLUtils.initHooks();