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

KAFKA-17162: join() started thread in DefaultTaskManagerTest (#18570) 

Reviewers: Lucas Brutschy <lbrutschy@confluent.io>
This commit is contained in:
Matthias J. Sax 2025-01-27 16:48:07 -08:00 committed by GitHub
parent e89b30d14e
commit dc396f47e8
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
streams/src/test/java/org/apache/kafka/streams/processor/internals/tasks/DefaultTaskManagerTest.java
View File

@ -137,6 +137,7 @@ public class DefaultTaskManagerTest {
assertFalse(awaitingRunnable.awaitDone.await(100, TimeUnit.MILLISECONDS)); assertFalse(awaitingRunnable.awaitDone.await(100, TimeUnit.MILLISECONDS));
awaitingRunnable.shutdown(); awaitingRunnable.shutdown();
awaitingThread.join();
} }
@Test @Test
@ -151,6 +152,7 @@ public class DefaultTaskManagerTest {
assertTrue(awaitingRunnable.awaitDone.await(VERIFICATION_TIMEOUT, TimeUnit.MILLISECONDS)); assertTrue(awaitingRunnable.awaitDone.await(VERIFICATION_TIMEOUT, TimeUnit.MILLISECONDS));
awaitingRunnable.shutdown(); awaitingRunnable.shutdown();
awaitingThread.join();
} }
@Test @Test
@ -165,6 +167,7 @@ public class DefaultTaskManagerTest {
assertTrue(awaitingRunnable.awaitDone.await(VERIFICATION_TIMEOUT, TimeUnit.MILLISECONDS)); assertTrue(awaitingRunnable.awaitDone.await(VERIFICATION_TIMEOUT, TimeUnit.MILLISECONDS));
awaitingRunnable.shutdown(); awaitingRunnable.shutdown();
awaitingThread.join();
} }
@Test @Test
@ -184,6 +187,7 @@ public class DefaultTaskManagerTest {
assertTrue(awaitingRunnable.awaitDone.await(VERIFICATION_TIMEOUT, TimeUnit.MILLISECONDS)); assertTrue(awaitingRunnable.awaitDone.await(VERIFICATION_TIMEOUT, TimeUnit.MILLISECONDS));
awaitingRunnable.shutdown(); awaitingRunnable.shutdown();
awaitingThread.join();
} }
@Test @Test
@ -198,6 +202,7 @@ public class DefaultTaskManagerTest {
assertTrue(awaitingRunnable.awaitDone.await(VERIFICATION_TIMEOUT, TimeUnit.MILLISECONDS)); assertTrue(awaitingRunnable.awaitDone.await(VERIFICATION_TIMEOUT, TimeUnit.MILLISECONDS));
awaitingRunnable.shutdown(); awaitingRunnable.shutdown();
awaitingThread.join();
} }
@Test @Test
@ -214,6 +219,7 @@ public class DefaultTaskManagerTest {
assertTrue(awaitingRunnable.awaitDone.await(VERIFICATION_TIMEOUT, TimeUnit.MILLISECONDS)); assertTrue(awaitingRunnable.awaitDone.await(VERIFICATION_TIMEOUT, TimeUnit.MILLISECONDS));
awaitingRunnable.shutdown(); awaitingRunnable.shutdown();
awaitingThread.join();
} }
@Test @Test