RankFusionProcessor processor = new RankFusionProcessor();
        processor.setSearcher(new TestSearcher(100));
        processor.init();

        // First close
        processor.close();
        // Second close - should not throw exception
        processor.close();
    }

    /**
     * Test searcher that returns configurable number of documents.
     */

     *
     * @param zos the ZIP output stream to write to
     * @param id the diagnostic ID for organizing files in the ZIP
     * @param v1 the first part of the API path (e.g., "cluster", "nodes")
     * @param v2 the second part of the API path (e.g., "health", "stats")
     */
    protected void writeElastisearchJsonApi(final ZipOutputStream zos, final String id, final String v1, final String v2) {

- Select a Adoptium Java 17 VM as "Gradle JVM"
- Revert the Git changes to files in the `.idea` folder

NOTE: Due to the project size, the very first import can take a while and IntelliJ might become unresponsive for several seconds during this period.

    /** Cache for storing group information to reduce API calls. */
    protected Cache<String, Pair<String[], String[]>> groupCache;

    /** Group cache expiry time in seconds. */
    protected long groupCacheExpiry = 10 * 60L;

    /** Maximum depth for processing nested groups to prevent infinite loops. */
    protected int maxGroupDepth = 10;

    /** Use V2 endpoint. */

String},n.fn=function(t){return"[object Function]"===Object.prototype.toString.call(t)}},370:function(t,e,n){var f=n(879),l=n(438);t.exports=function(t,e,n){if(!t&&!e&&!n)throw new Error("Missing required arguments");if(!f.string(e))throw new TypeError("Second argument must be a String");if(!f.fn(n))throw new TypeError("Third argument must be a Function");if(f.node(t))return c=e,a=n,(u=t).addEventListener(c,a),{destroy:function(){u.removeEventListener(c,a)}};if(f.nodeList(t))return o=t,r=e,i=n,Array.pr...

    public void close() throws Exception {
        if (executorService != null) {
            try {
                executorService.shutdown();
                executorService.awaitTermination(60, TimeUnit.SECONDS);
            } catch (final InterruptedException e) {
                if (logger.isDebugEnabled()) {
                    logger.debug("Executor shutdown interrupted", e);
                }
            } finally {

                    errorOccurred.set(true);
                } finally {
                    latch.countDown();
                }
            }).start();
        }

        latch.await(10, TimeUnit.SECONDS);
        assertFalse("No unexpected errors should occur during concurrent access", errorOccurred.get());
    }

    /**
     * Test that default groups and roles are preserved during lazy loading.
     */

     * Gets the model name.
     *
     * @return the model name
     */
    protected abstract String getModel();

    /**
     * Gets the availability check interval in seconds.
     *
     * @return the interval in seconds
     */
    protected abstract int getAvailabilityCheckInterval();

    /**
     * Checks if RAG chat feature is enabled.
     *
     * @return true if RAG chat is enabled

        System.setProperty("fess.webapp.path", webappDir.toString());
        System.setProperty("fess.conf.path", confDir.toString());

        // Path under webapp (second property) should be valid
        final File testFile = new File(webappDir.toFile(), "test.html");
        testFile.createNewFile();

        action.validateFilePath(testFile.getAbsolutePath());
    }

                execJob.jvmOptions("-Xms" + i + "m");
            }
            latch.countDown();
        });

        t1.start();
        t2.start();

        assertTrue(latch.await(5, TimeUnit.SECONDS));
        // The exact size may vary due to concurrent modifications, just check it's not empty
        assertTrue(execJob.jvmOptions.size() > 0);
    }

    // Test pattern matching in custom properties
    @Test