[kafka] branch 2.6 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.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 <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 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,