(kafka) branch trunk updated: KAFKA-19286: Fix flaky testConcurrentRemoveReadForCache1 (#20893)

[mimaison]

This is an automated email from the ASF dual-hosted git repository.

mimaison pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new c7bdabf9200 KAFKA-19286: Fix flaky testConcurrentRemoveReadForCache1 
(#20893)
c7bdabf9200 is described below

commit c7bdabf9200c688e17a563a217d59b5927111090
Author: Uladzislau Blok <123193120+uladzislaub...@users.noreply.github.com>
AuthorDate: Thu Dec 4 15:42:08 2025 +0100

    KAFKA-19286: Fix flaky testConcurrentRemoveReadForCache1 (#20893)
    
    
    Reviewers: Mickael Maison <mickael.mai...@gmail.com>
---
 .../org/apache/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 25c8bce5c3a..a47cc4ef987 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 @@ package org.apache.kafka.storage.internals.log;
 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 class RemoteIndexCacheTest {
         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 class RemoteIndexCacheTest {
     }
 
     @Test
-    @Flaky("KAFKA-19286")
     public void testConcurrentRemoveReadForCache1() throws IOException, 
InterruptedException, ExecutionException {
         // Create a spy Cache Entry
         RemoteIndexCache.Entry spyEntry = generateSpyCacheEntry();