From a940910f2e7fa73912d24e7538042c1c3dd8bbe7 Mon Sep 17 00:00:00 2001 From: Yupeng Fu Date: Sat, 18 Jan 2025 09:50:52 -0800 Subject: [PATCH] try fix thread leak Signed-off-by: Yupeng Fu --- .../java/org/opensearch/plugin/kafka/IngestFromKafkaIT.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/plugins/ingestion-kafka/src/internalClusterTest/java/org/opensearch/plugin/kafka/IngestFromKafkaIT.java b/plugins/ingestion-kafka/src/internalClusterTest/java/org/opensearch/plugin/kafka/IngestFromKafkaIT.java index c735e996bcaf5..7af5fe1ea013b 100644 --- a/plugins/ingestion-kafka/src/internalClusterTest/java/org/opensearch/plugin/kafka/IngestFromKafkaIT.java +++ b/plugins/ingestion-kafka/src/internalClusterTest/java/org/opensearch/plugin/kafka/IngestFromKafkaIT.java @@ -8,6 +8,7 @@ package org.opensearch.plugin.kafka; +import com.carrotsearch.randomizedtesting.annotations.ThreadLeakLingering; import org.apache.kafka.clients.producer.KafkaProducer; import org.apache.kafka.clients.producer.Producer; import org.apache.kafka.clients.producer.ProducerRecord; @@ -43,6 +44,7 @@ /** * Integration test for Kafka ingestion */ +@ThreadLeakLingering(linger = 5000) // wait for container pull thread to die public class IngestFromKafkaIT extends OpenSearchIntegTestCase { static final String topicName = "test";