[kafka] branch 2.7 updated: MINOR: fix record time in test shouldWipeOutStandbyStateDirectoryIfCheckpointIsMissing (#9948)

[mjsax]

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

mjsax pushed a commit to branch 2.7
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/2.7 by this push:
     new 9511a26  MINOR: fix record time in test 
shouldWipeOutStandbyStateDirectoryIfCheckpointIsMissing (#9948)
9511a26 is described below

commit 9511a26dca65f11f940567b8ee31fc9d0259ffe9
Author: Walker Carlson <18128741+wcarls...@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 <matth...@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 0cf351e..93b4f2f 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
@@ -175,6 +175,7 @@ public class StandbyTaskEOSIntegrationTest {
 
     @Test
     public void shouldWipeOutStandbyStateDirectoryIfCheckpointIsMissing() 
throws Exception {
+        final long time = System.currentTimeMillis();
         final String base = TestUtils.tempDirectory(appId).getPath();
 
         IntegrationTestUtils.produceKeyValuesSynchronouslyWithTimestamp(
@@ -188,7 +189,7 @@ public class StandbyTaskEOSIntegrationTest {
                 IntegerSerializer.class,
                 new Properties()
             ),
-            10L
+            10L + time
         );
 
         try (
@@ -243,7 +244,7 @@ public class StandbyTaskEOSIntegrationTest {
                     IntegerSerializer.class,
                     new Properties()
                 ),
-                10L
+                10L + time
             );
             waitForCondition(
                 () -> streamInstanceOne.state() == KafkaStreams.State.ERROR,
@@ -302,7 +303,7 @@ public class StandbyTaskEOSIntegrationTest {
                     IntegerSerializer.class,
                     new Properties()
                 ),
-                10L
+                10L + time
             );
             waitForCondition(
                 () -> streamInstanceOneRecovery.state() == 
KafkaStreams.State.ERROR,