if (exitValue != 0) {
                final StringBuilder out = new StringBuilder();
                if (processTimeout) {
                    out.append("Process is terminated due to ").append(timeout).append(" second exceeded.\n");
                }
                out.append("Exit Code: ").append(exitValue).append("\nOutput:\n").append(it.getOutput());
                throw new JobProcessingException(out.toString());
            }

        // First execution
        String result1 = aggregateLogJob.execute();
        assertNotNull(result1);
        assertTrue(result1.contains("Error 1"));

        // Second execution
        String result2 = aggregateLogJob.execute();
        assertNotNull(result2);
        assertTrue(result2.contains("Error 2"));

        // Results should be independent

                // First mock implementation
            }
        };

        // Create second customizer
        ComponentCustomizer customizer2 = new ComponentCustomizer() {
            @Override
            public void customize(org.lastaflute.di.core.ComponentDef componentDef) {
                // Second mock implementation
            }
        };

        // Set first customizer

        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.
     */

        // When
        DfFinalTimeZoneProvider provider = curtainBeforeHook.createFinalTimeZoneProvider();

        // Then
        TimeZone first = provider.provide();
        TimeZone second = provider.provide();
        assertSame(first, second, "Provider should return the same TimeZone instance");
    }

    @Test
    public void test_createFinalTimeZoneProvider_toStringContainsTimeZoneId() {
        // When

        testData.add(createRelatedQuery("test", new String[] { "second", "set" }, ""));
        mockBhv.setTestData(testData);

        relatedQueryHelper.load();

        // The second entry should overwrite the first one
        String[] results = relatedQueryHelper.getRelatedQueries("test");
        assertEquals(2, results.length);
        assertEquals("second", results[0]);
        assertEquals("set", results[1]);
    }

        testClient.reindexResult = true;
        testClient.deleteIndexResult = true;
        testClient.documentCount = 10;
        testClient.aliasCount = 2;
        // First createIndex (backup) succeeds, second (new) fails
        testClient.createIndexFailOnNth = 2;

        final boolean result = testClient.reindexConfigIndices(false, allTargetPrefixes());

        assertFalse(result);

            @Override
            public RescorerBuilder<?> evaluate(Map<String, Object> params) {
                return createMockRescorerBuilder();
            }
        };

        // Test with second implementation
        QueryRescorer rescorer2 = new QueryRescorer() {
            @Override
            public RescorerBuilder<?> evaluate(Map<String, Object> params) {
                return null;
            }

        configHelper.setLoadCallback(() -> {
            latch.countDown();
            return 1;
        });

        configHelper.update();

        assertTrue("Load method should be called within 5 seconds", latch.await(5, TimeUnit.SECONDS));
        assertEquals(1, configHelper.getLoadCallCount());
    }

    @Test
    public void test_update_multipleCallsIncrementLoadCount() throws InterruptedException {

        // Initial value
        assertEquals(0L, item.getId());

        // First modification
        item.id = 50L;
        assertEquals(50L, item.getId());

        // Second modification
        item.id = 100L;
        assertEquals(100L, item.getId());

        // Third modification back to 0
        item.id = 0L;
        assertEquals(0L, item.getId());
    }

    /**