From d1a246d1d5aba9d8e360dafcf9dedd482f6bf9f5 Mon Sep 17 00:00:00 2001 From: Zhong Date: Tue, 26 Sep 2017 16:57:44 +0800 Subject: [PATCH] APACHE-KYLIN-2905: Refine the process of submitting a job --- .../main/java/org/apache/kylin/job/execution/ExecutableManager.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/core-job/src/main/java/org/apache/kylin/job/execution/ExecutableManager.java b/core-job/src/main/java/org/apache/kylin/job/execution/ExecutableManager.java index bc38fff..c41c074 100644 --- a/core-job/src/main/java/org/apache/kylin/job/execution/ExecutableManager.java +++ b/core-job/src/main/java/org/apache/kylin/job/execution/ExecutableManager.java @@ -109,8 +109,11 @@ public class ExecutableManager { public void addJob(AbstractExecutable executable) { try { executable.initConfig(config); - executableDao.addJob(parse(executable)); + if (executableDao.getJob(executable.getId()) != null) { + throw new IllegalArgumentException("job id:" + executable.getId() + " already exists"); + } addJobOutput(executable); + executableDao.addJob(parse(executable)); } catch (PersistentException e) { logger.error("fail to submit job:" + executable.getId(), e); throw new RuntimeException(e); -- 2.5.4 (Apple Git-61)