(kafka) branch trunk updated: MINOR: Add more debug logging to EOSUncleanShutdownIntegrationTest (#16490)

[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 a9b2b36908e MINOR: Add more debug logging to 
EOSUncleanShutdownIntegrationTest (#16490)
a9b2b36908e is described below

commit a9b2b36908ed1c21f991ec8945c8fe9e2c42b2e3
Author: Matthias J. Sax <matth...@confluent.io>
AuthorDate: Sun Jul 14 10:28:31 2024 -0700

    MINOR: Add more debug logging to EOSUncleanShutdownIntegrationTest (#16490)
    
    Reviewers: Bruno Cadonna <br...@confluent.io>
---
 .../kafka/streams/integration/EOSUncleanShutdownIntegrationTest.java | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/streams/src/test/java/org/apache/kafka/streams/integration/EOSUncleanShutdownIntegrationTest.java
 
b/streams/src/test/java/org/apache/kafka/streams/integration/EOSUncleanShutdownIntegrationTest.java
index 90193c64cb1..ed67049aaa9 100644
--- 
a/streams/src/test/java/org/apache/kafka/streams/integration/EOSUncleanShutdownIntegrationTest.java
+++ 
b/streams/src/test/java/org/apache/kafka/streams/integration/EOSUncleanShutdownIntegrationTest.java
@@ -127,6 +127,9 @@ public class EOSUncleanShutdownIntegrationTest {
         driver.cleanUp();
         driver.start();
 
+        TestUtils.waitForCondition(() -> driver.state().equals(State.RUNNING),
+            "Expected RUNNING state but driver is on " + driver.state());
+
         // Task's StateDir
         final File taskStateDir = new File(String.join("/", 
TEST_FOLDER.getPath(), appId, "0_0"));
         final File taskCheckpointFile = new File(taskStateDir, ".checkpoint");
@@ -144,6 +147,8 @@ public class EOSUncleanShutdownIntegrationTest {
 
             TestUtils.waitForCondition(() -> recordCount.get() == RECORD_TOTAL,
                 "Expected " + RECORD_TOTAL + " records processed but only got 
" + recordCount.get());
+        } catch (final Exception e) {
+            e.printStackTrace();
         } finally {
             TestUtils.waitForCondition(() -> 
driver.state().equals(State.ERROR),
                 "Expected ERROR state but driver is on " + driver.state());