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 2021/01/23 00:18:37 UTC
[kafka] branch 2.6 updated: MINOR: fix record time in test
shouldWipeOutStandbyStateDirectoryIfCheckpointIsMissing (#9948)
This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a commit to branch 2.6
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.6 by this push:
new 3923afa MINOR: fix record time in test shouldWipeOutStandbyStateDirectoryIfCheckpointIsMissing (#9948)
3923afa is described below
commit 3923afa371565076ebcac893e7c007b148a6317c
Author: Walker Carlson <18...@users.noreply.github.com>
AuthorDate: Fri Jan 22 15:55:05 2021 -0800
MINOR: fix record time in test shouldWipeOutStandbyStateDirectoryIfCheckpointIsMissing (#9948)
Reviewer: Matthias J. Sax <ma...@confluent.io>
---
.../kafka/streams/integration/StandbyTaskEOSIntegrationTest.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/StandbyTaskEOSIntegrationTest.java b/streams/src/test/java/org/apache/kafka/streams/integration/StandbyTaskEOSIntegrationTest.java
index 27741a5..e57aa0a 100644
--- a/streams/src/test/java/org/apache/kafka/streams/integration/StandbyTaskEOSIntegrationTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/integration/StandbyTaskEOSIntegrationTest.java
@@ -182,6 +182,7 @@ public class StandbyTaskEOSIntegrationTest {
@Test
public void shouldWipeOutStandbyStateDirectoryIfCheckpointIsMissing() throws Exception {
+ final long time = System.currentTimeMillis();
final String base = TestUtils.tempDirectory(appId).getPath();
IntegrationTestUtils.produceKeyValuesSynchronouslyWithTimestamp(
@@ -195,7 +196,7 @@ public class StandbyTaskEOSIntegrationTest {
IntegerSerializer.class,
new Properties()
),
- 10L
+ 10L + time
);
try (
@@ -250,7 +251,7 @@ public class StandbyTaskEOSIntegrationTest {
IntegerSerializer.class,
new Properties()
),
- 10L
+ 10L + time
);
waitForCondition(
() -> streamInstanceOne.state() == KafkaStreams.State.ERROR,
@@ -309,7 +310,7 @@ public class StandbyTaskEOSIntegrationTest {
IntegerSerializer.class,
new Properties()
),
- 10L
+ 10L + time
);
waitForCondition(
() -> streamInstanceOneRecovery.state() == KafkaStreams.State.ERROR,