root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

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 <aschofield@confluent.io>
This commit is contained in:
Apoorv Mittal 2025-02-28 08:49:59 +00:00 committed by GitHub
parent f6ec7df27e
commit 8b605bd362
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 0 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
core/src/test/java/kafka/server/share/SharePartitionManagerTest.java
View File

@ -47,7 +47,6 @@ import org.apache.kafka.common.requests.FetchRequest;
import org.apache.kafka.common.requests.ShareFetchRequest; import org.apache.kafka.common.requests.ShareFetchRequest;
import org.apache.kafka.common.requests.ShareFetchResponse; import org.apache.kafka.common.requests.ShareFetchResponse;
import org.apache.kafka.common.requests.ShareRequestMetadata; 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.ImplicitLinkedHashCollection;
import org.apache.kafka.common.utils.MockTime; import org.apache.kafka.common.utils.MockTime;
import org.apache.kafka.common.utils.Time; import org.apache.kafka.common.utils.Time;
@ -1260,7 +1259,6 @@ public class SharePartitionManagerTest {
); );
} }
@Flaky("KAFKA-18657")
@Test @Test
public void testReplicaManagerFetchShouldProceed() { public void testReplicaManagerFetchShouldProceed() {
String groupId = "grp"; String groupId = "grp";
@ -2298,7 +2296,6 @@ public class SharePartitionManagerTest {
shareGroupMetrics.close(); shareGroupMetrics.close();
} }
@Flaky("KAFKA-18657")
@Test @Test
public void testDelayedInitializationShouldCompleteFetchRequest() { public void testDelayedInitializationShouldCompleteFetchRequest() {
String groupId = "grp"; String groupId = "grp";