This is an automated email from the ASF dual-hosted git repository.
davidarthur 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 f18457f2b8f MINOR Mark a StickyAssignorTest as flaky (#18719)
f18457f2b8f is described below
commit f18457f2b8f7adc5fb8ea2c46dcf38973aaf4667
Author: David Arthur <[email protected]>
AuthorDate: Tue Jan 28 10:34:05 2025 -0500
MINOR Mark a StickyAssignorTest as flaky (#18719)
Mark StickyAssignorTest#testLargeAssignmentAndGroupWithNonEqualSubscription
as flaky. Used data from this
report https://github.com/apache/kafka/actions/runs/12982945953
Reviewers: Andrew Schofield <[email protected]>
---
.../kafka/clients/consumer/internals/AbstractStickyAssignorTest.java | 2 ++
1 file changed, 2 insertions(+)
diff --git
a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignorTest.java
b/clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignorTest.java
index ee6df4e65a2..fe6b4d100ff 100644
---
a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignorTest.java
+++
b/clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignorTest.java
@@ -22,6 +22,7 @@ import org.apache.kafka.clients.consumer.StickyAssignor;
import
org.apache.kafka.clients.consumer.internals.AbstractPartitionAssignorTest.RackConfig;
import org.apache.kafka.common.PartitionInfo;
import org.apache.kafka.common.TopicPartition;
+import org.apache.kafka.common.test.api.Flaky;
import org.apache.kafka.common.utils.CollectionUtils;
import org.apache.kafka.common.utils.Utils;
@@ -741,6 +742,7 @@ public abstract class AbstractStickyAssignorTest {
assignor.assignPartitions(partitionsPerTopic, subscriptions);
}
+ @Flaky("KAFKA-13514")
@Timeout(90)
@ParameterizedTest(name = TEST_NAME_WITH_CONSUMER_RACK)
@ValueSource(booleans = {false, true})