\r
private static final Logger log = Logger.getLogger(LocalRunner.class);\r
/*\r
- * If is not advisable to start threads statically, thus this field is not\r
- * static\r
+ * If is not advisable to start threads statically, thus this field is not static\r
*/\r
private final ExecutorService executor;\r
private final ConfiguredExecutable<?> executable;\r
\r
public LocalRunner(ConfiguredExecutable<?> executable) {\r
if (executable == null) {\r
- throw new IllegalArgumentException(\r
- "Executable value is NULL. Executable must be provided!");\r
+ throw new IllegalArgumentException("Executable value is NULL. Executable must be provided!");\r
}\r
this.executor = LocalExecutorService.getExecutor();\r
this.executable = executable;\r
try {\r
executable.saveRunConfiguration();\r
} catch (IOException e) {\r
- log.error("Could not save run configuration! " + e.getMessage(), e\r
- .getCause());\r
+ log.error("Could not save run configuration! " + e.getMessage(), e.getCause());\r
}\r
}\r
\r
}\r
\r
@Override\r
- public void executeJob() throws JobSubmissionException {\r
- ExecutableWrapper ewrapper = new ExecutableWrapper(executable,\r
- workDirectory);\r
+ public void executeJob()\r
+ throws JobSubmissionException {\r
+ ExecutableWrapper ewrapper = new ExecutableWrapper(executable, workDirectory);\r
this.future = executor.submit(ewrapper);\r
}\r
\r
* @throws CancellationException\r
*/\r
@Override\r
- public ConfiguredExecutable<?> waitForResult() throws JobExecutionException {\r
+ public ConfiguredExecutable<?> waitForResult()\r
+ throws JobExecutionException {\r
try {\r
return LocalEngineUtil.getResults(future, executable.getTaskId());\r
} catch (ResultNotAvailableException e) {\r