fix: force deletion of WAL file after timeout

Author: lvca

engine/src/main/java/com/arcadedb/engine/TransactionManager.java

@@ -132,7 +132,7 @@ public void close(final boolean drop) {
       }
     }
 
-    if (!cleanWALFiles(drop, false))
+    if (!cleanWALFiles(drop, drop))
       LogManager.instance()
           .log(this, Level.WARNING, "Error on removing all transaction files. Remained: %s", null, inactiveWALFilePool);
     else {

gremlin/src/test/java/com/arcadedb/server/gremlin/GremlinMergeVStressTest.java

@@ -104,13 +104,13 @@ public String call() {
               List<Map<String, Object>> queryInputParams = createQueryInputParams(batchSize, threadId, iteration, nOfProperties);
               Map<String, Object> params = Map.of("rows", queryInputParams);
 
-              if (attempt > 0) {
-                System.out.println(Thread.currentThread().getName() + " (id=" + Thread.currentThread().threadId() +
-                    ") Iteration " + iteration + " RETRY #" + attempt + " importing " + batchSize + " entries");
-              } else {
-                System.out.println(Thread.currentThread().getName() + " (id=" + Thread.currentThread().threadId() +
-                    ") Iteration " + iteration + " importing " + batchSize + " entries");
-              }
+//              if (attempt > 0) {
+//                System.out.println(Thread.currentThread().getName() + " (id=" + Thread.currentThread().threadId() +
+//                    ") Iteration " + iteration + " RETRY #" + attempt + " importing " + batchSize + " entries");
+//              } else {
+//                System.out.println(Thread.currentThread().getName() + " (id=" + Thread.currentThread().threadId() +
+//                    ") Iteration " + iteration + " importing " + batchSize + " entries");
+//              }
 
               int nOfResults = client.submit(query, params).all().join().size();
               totalInserted.addAndGet(nOfResults);
@@ -126,8 +126,8 @@ public String call() {
               if (errorMsg != null && (errorMsg.contains("Concurrent modification") ||
                   errorMsg.contains("ConcurrentModificationException"))) {
                 attempt++;
-                System.out.println(Thread.currentThread().getName() + " iteration " + iteration +
-                    " - Concurrent modification detected, retry " + attempt + "/" + maxRetries);
+//                System.out.println(Thread.currentThread().getName() + " iteration " + iteration +
+//                    " - Concurrent modification detected, retry " + attempt + "/" + maxRetries);
 
                 // Brief pause before retry
                 try {
@@ -186,7 +186,7 @@ private List<Map<String, Object>> createQueryInputParams(int batchSize, int thre
 
       // Run multiple iterations with high concurrency
       for (int iteration = 0; iteration < iterations; iteration++) {
-        System.out.println("\n=== Starting iteration " + iteration + " with " + nOfThreads + " threads ===");
+//        System.out.println("\n=== Starting iteration " + iteration + " with " + nOfThreads + " threads ===");
 
         ExecutorService executorService = Executors.newFixedThreadPool(nOfThreads);
         ExecutorCompletionService<String> completionService = new ExecutorCompletionService<>(executorService);
@@ -200,7 +200,7 @@ private List<Map<String, Object>> createQueryInputParams(int batchSize, int thre
           try {
             Future<String> future = completionService.take();
             String result = future.get();
-            System.out.println("Results from " + result);
+//            System.out.println("Results from " + result);
             receivedResults++;
           } catch (InterruptedException e) {
             Thread.currentThread().interrupt();
@@ -231,8 +231,8 @@ private List<Map<String, Object>> createQueryInputParams(int batchSize, int thre
             .next().getProperty("count");
 
         long expectedCount = (long) nOfThreads * batchSize * iterations;
-        System.out.println("\nTotal vertices created: " + count + ", expected: " + expectedCount);
-        System.out.println("Total inserted reported by threads: " + totalInserted.get());
+//        System.out.println("\nTotal vertices created: " + count + ", expected: " + expectedCount);
+//        System.out.println("Total inserted reported by threads: " + totalInserted.get());
 
         assertThat(count.longValue()).isEqualTo(expectedCount);
         assertThat(totalInserted.get()).isEqualTo(expectedCount);