@Override
    public void close() {
        diskCacheManager.close();
    }
@Test
    void testRelease() {
        AtomicBoolean isReleased = new AtomicBoolean(false);
        TestingPartitionFileWriter partitionFileWriter =
                new TestingPartitionFileWriter.Builder()
                        .setReleaseRunnable(() -> isReleased.set(true))
                        .build();
        TieredStorageResourceRegistry resourceRegistry = new TieredStorageResourceRegistry();

        DiskTierProducerAgent diskTierProducerAgent =
                createDiskTierProducerAgent(
                        false,
                        NUM_BYTES_PER_SEGMENT,
                        0,
                        tempFolder.toString(),
                        partitionFileWriter,
                        resourceRegistry);
        diskTierProducerAgent.close();
        resourceRegistry.clearResourceFor(PARTITION_ID);
        assertThat(isReleased).isTrue();
    }