Skip to content

Commit c7bdabf

Browse files
KAFKA-19286: Fix flaky testConcurrentRemoveReadForCache1 (#20893)
Reviewers: Mickael Maison <mickael.maison@gmail.com>
1 parent d31dfa0 commit c7bdabf

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

storage/src/test/java/org/apache/kafka/storage/internals/log/RemoteIndexCacheTest.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,6 @@
1919
import org.apache.kafka.common.TopicIdPartition;
2020
import org.apache.kafka.common.TopicPartition;
2121
import org.apache.kafka.common.Uuid;
22-
import org.apache.kafka.common.test.api.Flaky;
2322
import org.apache.kafka.common.utils.Utils;
2423
import org.apache.kafka.server.log.remote.storage.RemoteLogSegmentId;
2524
import org.apache.kafka.server.log.remote.storage.RemoteLogSegmentMetadata;
@@ -122,7 +121,7 @@ public void setup() throws IOException, RemoteStorageException {
122121
rlsMetadata = new RemoteLogSegmentMetadata(remoteLogSegmentId, baseOffset, lastOffset, time.milliseconds(),
123122
brokerId, time.milliseconds(), segmentSize, Collections.singletonMap(0, 0L));
124123
cache = new RemoteIndexCache(defaultRemoteIndexCacheSizeBytes, rsm, logDir.toString());
125-
cache.setFileDeleteDelayMs(0);
124+
cache.setFileDeleteDelayMs(20);
126125
mockRsmFetchIndex(rsm);
127126
}
128127

@@ -773,7 +772,6 @@ public void testCorruptCacheIndexFileExistsButNotInCache(IndexType indexType) th
773772
}
774773

775774
@Test
776-
@Flaky("KAFKA-19286")
777775
public void testConcurrentRemoveReadForCache1() throws IOException, InterruptedException, ExecutionException {
778776
// Create a spy Cache Entry
779777
RemoteIndexCache.Entry spyEntry = generateSpyCacheEntry();

0 commit comments

Comments
 (0)