From cfb18f5b61401c28d30a67ac4fbc8d0c1f12ce6f Mon Sep 17 00:00:00 2001 From: Jim Hughes Date: Wed, 1 Jun 2022 15:59:14 -0400 Subject: [PATCH] Updating TaskExecutorMetadataTest. --- .../processor/internals/TaskExecutionMetadataTest.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskExecutionMetadataTest.java b/streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskExecutionMetadataTest.java index c1c11286c582..18ae1515a4dc 100644 --- a/streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskExecutionMetadataTest.java +++ b/streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskExecutionMetadataTest.java @@ -33,8 +33,7 @@ public class TaskExecutionMetadataTest { final static String TOPOLOGY1 = "topology1"; final static String TOPOLOGY2 = "topology2"; final static Set NAMED_TOPOLOGIES = new HashSet<>(Arrays.asList(TOPOLOGY1, TOPOLOGY2)); - final static int TIME_ZERO = 0; - final static int ONE_SECOND = 1000; + final static int TIME_ZERO = 0; final static int CONSTANT_BACKOFF_MS = 5000; @Test @@ -108,8 +107,8 @@ public void testNamedTopologiesCanBackoff() { Assert.assertTrue(metadata.canProcessTask(mockTask2, TIME_ZERO)); metadata.registerTaskError(mockTask1, new Throwable("Error"), TIME_ZERO); - Assert.assertFalse(metadata.canProcessTask(mockTask1, ONE_SECOND)); - Assert.assertTrue(metadata.canProcessTask(mockTask2, ONE_SECOND)); + Assert.assertFalse(metadata.canProcessTask(mockTask1, CONSTANT_BACKOFF_MS - 1)); + Assert.assertTrue(metadata.canProcessTask(mockTask2, CONSTANT_BACKOFF_MS - 1)); Assert.assertFalse(metadata.canProcessTask(mockTask1, CONSTANT_BACKOFF_MS)); Assert.assertTrue(metadata.canProcessTask(mockTask2, CONSTANT_BACKOFF_MS));