KYLIN-2378 Set job thread name with job uuid
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/0f36b9b3 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/0f36b9b3 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/0f36b9b3 Branch: refs/heads/master-cdh5.7 Commit: 0f36b9b37097b95c16dd62cbe32781e5af8911dc Parents: a11a31d Author: kangkaisen <kangkai...@live.com> Authored: Mon Jan 9 17:21:38 2017 +0800 Committer: kangkaisen <kangkai...@163.com> Committed: Thu Jan 12 17:42:54 2017 +0800 ---------------------------------------------------------------------- .../org/apache/kylin/job/impl/threadpool/DefaultScheduler.java | 3 ++- .../apache/kylin/job/impl/threadpool/DistributedScheduler.java | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/0f36b9b3/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 ddb3a21..403abc4 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 @@ -29,6 +29,7 @@ import java.util.concurrent.TimeUnit; import org.apache.curator.framework.CuratorFramework; import org.apache.curator.framework.state.ConnectionState; import org.apache.curator.framework.state.ConnectionStateListener; +import org.apache.kylin.common.util.SetThreadName; import org.apache.kylin.job.Scheduler; import org.apache.kylin.job.constant.ExecutableConstants; import org.apache.kylin.job.engine.JobEngineConfig; @@ -137,7 +138,7 @@ public class DefaultScheduler implements Scheduler<AbstractExecutable>, Connecti @Override public void run() { - try { + try (SetThreadName ignored = new SetThreadName("Job %s", executable.getId())) { executable.execute(context); // trigger the next step asap fetcherPool.schedule(fetcher, 0, TimeUnit.SECONDS); http://git-wip-us.apache.org/repos/asf/kylin/blob/0f36b9b3/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/DistributedScheduler.java ---------------------------------------------------------------------- diff --git a/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/DistributedScheduler.java b/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/DistributedScheduler.java index be07d76..3436529 100644 --- a/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/DistributedScheduler.java +++ b/core-job/src/main/java/org/apache/kylin/job/impl/threadpool/DistributedScheduler.java @@ -35,6 +35,7 @@ import org.apache.curator.framework.CuratorFramework; import org.apache.curator.framework.state.ConnectionState; import org.apache.curator.framework.state.ConnectionStateListener; import org.apache.kylin.common.KylinConfig; +import org.apache.kylin.common.util.SetThreadName; import org.apache.kylin.job.Scheduler; import org.apache.kylin.job.constant.ExecutableConstants; import org.apache.kylin.job.engine.JobEngineConfig; @@ -173,7 +174,7 @@ public class DistributedScheduler implements Scheduler<AbstractExecutable>, Conn @Override public void run() { - try { + try (SetThreadName ignored = new SetThreadName("Job %s", executable.getId())) { String segmentId = executable.getParam(SEGMENT_ID); if (jobLock.lockWithName(segmentId, serverName)) { logger.info(executable.toString() + " scheduled in server: " + serverName);
