InstanceService { public void clearTriggerFlag() { jobNodeStorage.updateJobNode(instanceNode.getLocalInstanceNode(), ""); } InstanceService(final CoordinatorRegistryCenter regCenter, final String jobName); void persistOnline(); void removeInstance(); void clearTriggerFlag(); List<JobInstance> getAvailableJobInstances(); boolean isLocalJobInstanceExisted();  }
@Test public void assertClearTriggerFlag() { instanceService.clearTriggerFlag(); jobNodeStorage.updateJobNode("instances/127.0.0.1@-@0", ""); }