(kafka) branch trunk updated: KAFKA-17162: join() started thread in DefaultTaskManagerTest (#18570)

[mjsax]

This is an automated email from the ASF dual-hosted git repository.

mjsax 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 dc396f47e8f KAFKA-17162: join() started thread in 
DefaultTaskManagerTest (#18570)
dc396f47e8f is described below

commit dc396f47e8f7b82eef8b33c7a6153f5ed3a1127f
Author: Matthias J. Sax <matth...@confluent.io>
AuthorDate: Mon Jan 27 16:48:07 2025 -0800

    KAFKA-17162: join() started thread in DefaultTaskManagerTest (#18570)
    
    Reviewers: Lucas Brutschy <lbruts...@confluent.io>
---
 .../streams/processor/internals/tasks/DefaultTaskManagerTest.java   | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git 
a/streams/src/test/java/org/apache/kafka/streams/processor/internals/tasks/DefaultTaskManagerTest.java
 
b/streams/src/test/java/org/apache/kafka/streams/processor/internals/tasks/DefaultTaskManagerTest.java
index 137f089dd0f..0261ac99720 100644
--- 
a/streams/src/test/java/org/apache/kafka/streams/processor/internals/tasks/DefaultTaskManagerTest.java
+++ 
b/streams/src/test/java/org/apache/kafka/streams/processor/internals/tasks/DefaultTaskManagerTest.java
@@ -137,6 +137,7 @@ public class DefaultTaskManagerTest {
         assertFalse(awaitingRunnable.awaitDone.await(100, 
TimeUnit.MILLISECONDS));
 
         awaitingRunnable.shutdown();
+        awaitingThread.join();
     }
 
     @Test
@@ -151,6 +152,7 @@ public class DefaultTaskManagerTest {
         assertTrue(awaitingRunnable.awaitDone.await(VERIFICATION_TIMEOUT, 
TimeUnit.MILLISECONDS));
 
         awaitingRunnable.shutdown();
+        awaitingThread.join();
     }
 
     @Test
@@ -165,6 +167,7 @@ public class DefaultTaskManagerTest {
         assertTrue(awaitingRunnable.awaitDone.await(VERIFICATION_TIMEOUT, 
TimeUnit.MILLISECONDS));
 
         awaitingRunnable.shutdown();
+        awaitingThread.join();
     }
 
     @Test
@@ -184,6 +187,7 @@ public class DefaultTaskManagerTest {
         assertTrue(awaitingRunnable.awaitDone.await(VERIFICATION_TIMEOUT, 
TimeUnit.MILLISECONDS));
 
         awaitingRunnable.shutdown();
+        awaitingThread.join();
     }
 
     @Test
@@ -198,6 +202,7 @@ public class DefaultTaskManagerTest {
         assertTrue(awaitingRunnable.awaitDone.await(VERIFICATION_TIMEOUT, 
TimeUnit.MILLISECONDS));
 
         awaitingRunnable.shutdown();
+        awaitingThread.join();
     }
 
     @Test
@@ -214,6 +219,7 @@ public class DefaultTaskManagerTest {
         assertTrue(awaitingRunnable.awaitDone.await(VERIFICATION_TIMEOUT, 
TimeUnit.MILLISECONDS));
 
         awaitingRunnable.shutdown();
+        awaitingThread.join();
     }
 
     @Test