@Test public void testCancel() throws IOException { createAndRunTask(); this.task.cancel(); verify(this.mockProcess).destroyForcibly(); }
@Override public void cancel() { logger.info(String .format("Canceling a single task process. job name: %s. job id: %s", this.jobName, this.jobId)); this.taskProcess.destroyForcibly(); }
SingleHelixTask implements Task { @Override public void cancel() { logger.info(String .format("Canceling a single task process. job name: %s. job id: %s", this.jobName, this.jobId)); this.taskProcess.destroyForcibly(); } }
SingleHelixTask implements Task { @Override public void cancel() { logger.info(String .format("Canceling a single task process. job name: %s. job id: %s", this.jobName, this.jobId)); this.taskProcess.destroyForcibly(); } SingleHelixTask(final SingleTaskLauncher launcher, final Map<String, String> configMap); }
SingleHelixTask implements Task { @Override public void cancel() { logger.info(String .format("Canceling a single task process. job name: %s. job id: %s", this.jobName, this.jobId)); this.taskProcess.destroyForcibly(); } SingleHelixTask(final SingleTaskLauncher launcher, final Map<String, String> configMap); @Override TaskResult run(); @Override void cancel(); }
SingleHelixTask implements Task { @Override public void cancel() { logger.info(String .format("Canceling a single task process. job name: %s. job id: %s", this.jobName, this.jobId)); this.taskProcess.destroyForcibly(); } SingleHelixTask(final SingleTaskLauncher launcher, final Map<String, String> configMap); @Override TaskResult run(); @Override void cancel();  }