diff --git a/src/test/java/com/yahoo/bullet/windowing/AdditiveTumblingTest.java b/src/test/java/com/yahoo/bullet/windowing/AdditiveTumblingTest.java index d77664d7..bc0a7bd8 100644 --- a/src/test/java/com/yahoo/bullet/windowing/AdditiveTumblingTest.java +++ b/src/test/java/com/yahoo/bullet/windowing/AdditiveTumblingTest.java @@ -124,7 +124,6 @@ public void testResetting() throws Exception { long newCloseTime = additiveTumbling.nextCloseTime; Assert.assertTrue(resetTime > started); Assert.assertTrue(newCloseTime >= originalCloseTime + 1); - Assert.assertTrue(newCloseTime >= resetTime); // Aggregation should NOT have been reset Assert.assertEquals(strategy.getResetCalls(), 0); } @@ -150,7 +149,6 @@ public void testResettingInPartitionMode() throws Exception { long newCloseTime = additiveTumbling.nextCloseTime; Assert.assertTrue(resetTime > started); Assert.assertTrue(newCloseTime >= originalCloseTime + 1); - Assert.assertTrue(newCloseTime >= resetTime); // Aggregation should have been reset Assert.assertEquals(strategy.getResetCalls(), 1); } diff --git a/src/test/java/com/yahoo/bullet/windowing/TumblingTest.java b/src/test/java/com/yahoo/bullet/windowing/TumblingTest.java index 531c97fb..7d7ed16a 100644 --- a/src/test/java/com/yahoo/bullet/windowing/TumblingTest.java +++ b/src/test/java/com/yahoo/bullet/windowing/TumblingTest.java @@ -124,7 +124,6 @@ public void testResetting() throws Exception { long newCloseTime = tumbling.nextCloseTime; Assert.assertTrue(resetTime > started); Assert.assertTrue(newCloseTime >= originalCloseTime + 1); - Assert.assertTrue(newCloseTime >= resetTime); Assert.assertEquals(strategy.getResetCalls(), 1); } @@ -149,7 +148,6 @@ public void testResettingForPartition() throws Exception { long newCloseTime = tumbling.nextCloseTime; Assert.assertTrue(resetTime > started); Assert.assertTrue(newCloseTime >= originalCloseTime + 1); - Assert.assertTrue(newCloseTime >= resetTime); Assert.assertEquals(strategy.getResetCalls(), 1); }