Prevent intermittent test failure
@@ -820,7 +820,7 @@ public class Aggregation1TestCase {
stockStreamInputHandler.send(new Object[]{"IBM", 100f, null, 200L, 26, 1496289954000L});
stockStreamInputHandler.send(new Object[]{"IBM", 100f, null, 200L, 96, 1496289954000L});
- Thread.sleep(2000);
+ Thread.sleep(5000);
LocalDate currentDate = LocalDate.now();
String year = String.valueOf(currentDate.getYear());
