GuaranteeService { public void clearAllCompletedInfo() { jobNodeStorage.removeJobNodeIfExisted(GuaranteeNode.COMPLETED_ROOT); } GuaranteeService(final CoordinatorRegistryCenter coordinatorRegistryCenter, final JobConfiguration jobConfiguration); void registerStart(final Collection<Integer> shardingItems); boolean isAllStarted(); void clearAllStartedInfo(); void registerComplete(final Collection<Integer> shardingItems); boolean isAllCompleted(); void clearAllCompletedInfo();  }
@Test public void testClearAllCompletedInfo() { guaranteeService.clearAllCompletedInfo(); verify(jobNodeStorage).removeJobNodeIfExisted("guarantee/completed"); }