From 172512c8802aff2b3a07d7fd5de162dc6b25267b Mon Sep 17 00:00:00 2001 From: Uladzislau Blok Date: Sat, 15 Nov 2025 23:04:25 +0100 Subject: [PATCH] KAFKA-19286: Fix flaky RemoteIndexCacheTest.testConcurrentRemoveReadForCache1 --- .../kafka/storage/internals/log/RemoteIndexCacheTest.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/storage/src/test/java/org/apache/kafka/storage/internals/log/RemoteIndexCacheTest.java b/storage/src/test/java/org/apache/kafka/storage/internals/log/RemoteIndexCacheTest.java index 25c8bce5c3a1b..a47cc4ef987e9 100644 --- a/storage/src/test/java/org/apache/kafka/storage/internals/log/RemoteIndexCacheTest.java +++ b/storage/src/test/java/org/apache/kafka/storage/internals/log/RemoteIndexCacheTest.java @@ -19,7 +19,6 @@ import org.apache.kafka.common.TopicIdPartition; import org.apache.kafka.common.TopicPartition; import org.apache.kafka.common.Uuid; -import org.apache.kafka.common.test.api.Flaky; import org.apache.kafka.common.utils.Utils; import org.apache.kafka.server.log.remote.storage.RemoteLogSegmentId; import org.apache.kafka.server.log.remote.storage.RemoteLogSegmentMetadata; @@ -122,7 +121,7 @@ public void setup() throws IOException, RemoteStorageException { rlsMetadata = new RemoteLogSegmentMetadata(remoteLogSegmentId, baseOffset, lastOffset, time.milliseconds(), brokerId, time.milliseconds(), segmentSize, Collections.singletonMap(0, 0L)); cache = new RemoteIndexCache(defaultRemoteIndexCacheSizeBytes, rsm, logDir.toString()); - cache.setFileDeleteDelayMs(0); + cache.setFileDeleteDelayMs(20); mockRsmFetchIndex(rsm); } @@ -773,7 +772,6 @@ public void testCorruptCacheIndexFileExistsButNotInCache(IndexType indexType) th } @Test - @Flaky("KAFKA-19286") public void testConcurrentRemoveReadForCache1() throws IOException, InterruptedException, ExecutionException { // Create a spy Cache Entry RemoteIndexCache.Entry spyEntry = generateSpyCacheEntry();