(kafka) branch trunk updated: MINOR: Removing share partition manager flaky annotation (#19053)

[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 8b605bd3620 MINOR: Removing share partition manager flaky annotation 
(#19053)
8b605bd3620 is described below

commit 8b605bd3620268214a85c8a520cad22dec815358
Author: Apoorv Mittal <apoorvmitta...@gmail.com>
AuthorDate: Fri Feb 28 08:49:59 2025 +0000

    MINOR: Removing share partition manager flaky annotation (#19053)
    
    There isn't any flaky test for SharePartitionManager in last 7 days, 
removing flaky annotation.
    
    Reviewers: Andrew Schofield <aschofi...@confluent.io>
---
 core/src/test/java/kafka/server/share/SharePartitionManagerTest.java | 3 ---
 1 file changed, 3 deletions(-)

diff --git 
a/core/src/test/java/kafka/server/share/SharePartitionManagerTest.java 
b/core/src/test/java/kafka/server/share/SharePartitionManagerTest.java
index d758c032aaf..1ffee5dc7f6 100644
--- a/core/src/test/java/kafka/server/share/SharePartitionManagerTest.java
+++ b/core/src/test/java/kafka/server/share/SharePartitionManagerTest.java
@@ -47,7 +47,6 @@ import org.apache.kafka.common.requests.FetchRequest;
 import org.apache.kafka.common.requests.ShareFetchRequest;
 import org.apache.kafka.common.requests.ShareFetchResponse;
 import org.apache.kafka.common.requests.ShareRequestMetadata;
-import org.apache.kafka.common.test.api.Flaky;
 import org.apache.kafka.common.utils.ImplicitLinkedHashCollection;
 import org.apache.kafka.common.utils.MockTime;
 import org.apache.kafka.common.utils.Time;
@@ -1260,7 +1259,6 @@ public class SharePartitionManagerTest {
         );
     }
 
-    @Flaky("KAFKA-18657")
     @Test
     public void testReplicaManagerFetchShouldProceed() {
         String groupId = "grp";
@@ -2298,7 +2296,6 @@ public class SharePartitionManagerTest {
         shareGroupMetrics.close();
     }
 
-    @Flaky("KAFKA-18657")
     @Test
     public void testDelayedInitializationShouldCompleteFetchRequest() {
         String groupId = "grp";