(kafka) branch trunk updated: MINOR: Mark RemoteIndexCacheTest.testConcurrentRemoveReadForCache1 flaky (#19732)

[schofielaj]

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

schofielaj 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 7ae9a26fc2d MINOR: Mark 
RemoteIndexCacheTest.testConcurrentRemoveReadForCache1 flaky (#19732)
7ae9a26fc2d is described below

commit 7ae9a26fc2d3995b3b841797f3155fac12743f75
Author: Andrew Schofield <aschofi...@confluent.io>
AuthorDate: Fri May 16 09:03:08 2025 +0100

    MINOR: Mark RemoteIndexCacheTest.testConcurrentRemoveReadForCache1 flaky 
(#19732)
    
    Marking flaky test as a result of 5% failure rate.
    
    Reviewers: Chia-Ping Tsai <chia7...@gmail.com>
---
 .../org/apache/kafka/storage/internals/log/RemoteIndexCacheTest.java    | 2 ++
 1 file changed, 2 insertions(+)

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 d85304b3dd6..b1480d36775 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,6 +19,7 @@ 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;
@@ -760,6 +761,7 @@ public class RemoteIndexCacheTest {
     }
 
     @Test
+    @Flaky("KAFKA-19286")
     public void testConcurrentRemoveReadForCache1() throws IOException, 
InterruptedException, ExecutionException {
         // Create a spy Cache Entry
         RemoteIndexCache.Entry spyEntry = generateSpyCacheEntry();