Flaky test: TestTaskStorageManager testStoreLifecycleForLoggedPersistedStore

:samza-core_2.11:test

testStoreLifecycleForLoggedPersistedStore FAILED
    org.junit.ComparisonFailure: expected:<[]0> but was:<[10]0>
        at org.junit.Assert.assertEquals(Assert.java:123)
        at org.junit.Assert.assertEquals(Assert.java:145)
        at org.apache.samza.storage.TestTaskStorageManager$$anon$12.answer(TestTaskStorageManager.scala:106)
        at org.apache.samza.storage.TestTaskStorageManager$$anon$12.answer(TestTaskStorageManager.scala:100)
        at org.mockito.internal.stubbing.StubbedInvocationMatcher.answer(StubbedInvocationMatcher.java:34)
        at org.mockito.internal.handler.MockHandlerImpl.handle(MockHandlerImpl.java:91)
        at org.mockito.internal.handler.NullResultGuardian.handle(NullResultGuardian.java:29)
        at org.mockito.internal.handler.InvocationNotifierHandler.handle(InvocationNotifierHandler.java:38)
        at org.mockito.internal.creation.cglib.MethodInterceptorFilter.intercept(MethodInterceptorFilter.java:59)
        at org.apache.samza.system.SystemConsumer$$EnhancerByMockitoWithCGLIB$$7621939b.register(<generated>)
        at org.apache.samza.storage.TaskStorageManager$$anonfun$startConsumers$3.apply(TaskStorageManager.scala:244)
        at org.apache.samza.storage.TaskStorageManager$$anonfun$startConsumers$3.apply(TaskStorageManager.scala:234)
        at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:733)
        at scala.collection.immutable.Map$Map1.foreach(Map.scala:116)
        at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:732)
        at org.apache.samza.storage.TaskStorageManager.startConsumers(TaskStorageManager.scala:234)
        at org.apache.samza.storage.TaskStorageManager.init(TaskStorageManager.scala:87)
        at org.apache.samza.storage.TestTaskStorageManager.testStoreLifecycleForLoggedPersistedStore(TestTaskStorageManager.scala:133)

448 tests completed, 1 failed, 1 skipped
:samza-core_2.11:test FAILED