KYLIN-1189: Keep the status of pending jobs to be READY
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/d138d174 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/d138d174 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/d138d174 Branch: refs/heads/1.4-rc Commit: d138d174d2473648cf5e706e30e14efcace41d26 Parents: 7b80edb Author: kyotoYaho <nju_y...@apache.org> Authored: Fri Jun 17 15:25:14 2016 +0800 Committer: kyotoYaho <nju_y...@apache.org> Committed: Fri Jun 17 15:25:14 2016 +0800 ---------------------------------------------------------------------- .../org/apache/kylin/job/impl/threadpool/DefaultScheduler.java | 5 ----- 1 file changed, 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/d138d174/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/DefaultScheduler.java ---------------------------------------------------------------------- diff --git a/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/DefaultScheduler.java b/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/DefaultScheduler.java index 4abaa23..2915c60 100644 --- a/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/DefaultScheduler.java +++ b/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/DefaultScheduler.java @@ -170,11 +170,6 @@ public class DefaultScheduler implements Scheduler<AbstractExecutable>, Connecti jobPool = new ThreadPoolExecutor(corePoolSize, corePoolSize, Long.MAX_VALUE, TimeUnit.DAYS, new SynchronousQueue<Runnable>()); context = new DefaultContext(Maps.<String, Executable> newConcurrentMap(), jobEngineConfig.getConfig()); - for (AbstractExecutable executable : executableManager.getAllExecutables()) { - if (executable.getStatus() == ExecutableState.READY) { - executableManager.updateJobOutput(executable.getId(), ExecutableState.ERROR, null, "scheduler initializing work to reset job to ERROR status"); - } - } executableManager.resumeAllRunningJobs(); Runtime.getRuntime().addShutdownHook(new Thread() {
