Forcing the reexecute a flaky test trying to figure out the reason

castorm · May 22, 2020 · 2f2d88e · 2f2d88e
1 parent 0cd7454
commit 2f2d88e
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/src/test/java/com/github/castorm/kafka/connect/throttle/AdaptableIntervalThrottlerTest.java b/src/test/java/com/github/castorm/kafka/connect/throttle/AdaptableIntervalThrottlerTest.java
@@ -57,10 +57,10 @@ class AdaptableIntervalThrottlerTest {
 
     @BeforeEach
     void setUp() {
-        throttler = new AdaptableIntervalThrottler(__ -> config);
         given(tailThrottler.getIntervalMillis()).willReturn(intervalMillis);
         given(config.getTailThrottler()).willReturn(tailThrottler);
         given(config.getCatchupThrottler()).willReturn(catchupThrottler);
+        throttler = new AdaptableIntervalThrottler(__ -> config);
         throttler.configure(emptyMap());
     }
 
@@ -85,9 +85,11 @@ void givenNewRecordsLastNotLongAgo_whenThrottle_thenTailThrottler() throws Inter
     @Test
     void givenNewRecordsLastLongAgo_whenThrottle_thenCatchupThrottler() throws InterruptedException {
 
-        throttler.throttle(offset(now.minus(intervalMillis, MILLIS)));
+        Offset offset = offset(now.minus(intervalMillis, MILLIS));
 
-        then(catchupThrottler).should().throttle(offset(now.minus(intervalMillis, MILLIS)));
+        throttler.throttle(offset);
+
+        then(catchupThrottler).should().throttle(offset);
         then(tailThrottler).should(never()).throttle(any());
     }