You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by li...@apache.org on 2016/12/29 01:45:28 UTC
[2/7] kylin git commit: minor, fix could not parse issue for scheduler
minor, fix could not parse issue for scheduler
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/fd1ed2ed
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/fd1ed2ed
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/fd1ed2ed
Branch: refs/heads/yang22-hbase1.x
Commit: fd1ed2ed2fe7ddf7bfeac489aaa550d5171c687b
Parents: 7e74783
Author: Billy Liu <bi...@apache.org>
Authored: Wed Dec 28 19:00:00 2016 +0800
Committer: Billy Liu <bi...@apache.org>
Committed: Wed Dec 28 19:00:00 2016 +0800
----------------------------------------------------------------------
.../kylin/job/impl/threadpool/DefaultScheduler.java | 11 +++++++----
1 file changed, 7 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/fd1ed2ed/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 be8e7fe..ddb3a21 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
@@ -105,15 +105,18 @@ public class DefaultScheduler implements Scheduler<AbstractExecutable>, Connecti
continue;
}
nReady++;
- AbstractExecutable executable = executableManager.getJob(id);
- String jobDesc = executable.toString();
- logger.info(jobDesc + " prepare to schedule");
+ AbstractExecutable executable = null;
+ String jobDesc = null;
try {
+ executable = executableManager.getJob(id);
+ jobDesc = executable.toString();
+ logger.info(jobDesc + " prepare to schedule");
context.addRunningJob(executable);
jobPool.execute(new JobRunner(executable));
logger.info(jobDesc + " scheduled");
} catch (Exception ex) {
- context.removeRunningJob(executable);
+ if (executable != null)
+ context.removeRunningJob(executable);
logger.warn(jobDesc + " fail to schedule", ex);
}
}