You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2024/07/14 17:28:37 UTC
(kafka) branch trunk updated: MINOR: Add more debug logging to EOSUncleanShutdownIntegrationTest (#16490)
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 <ma...@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());