TEZ-2202. Fix LocalTaskExecutionThread ID to the standard thread numbering. (Gopal V via hitesh)
Project: http://git-wip-us.apache.org/repos/asf/tez/repo Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/664747ed Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/664747ed Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/664747ed Branch: refs/heads/TEZ-2003 Commit: 664747edf3add175fc612de2b0a7c3ed7381f16e Parents: 64df829 Author: Hitesh Shah <[email protected]> Authored: Tue Mar 17 14:57:30 2015 -0700 Committer: Hitesh Shah <[email protected]> Committed: Tue Mar 17 14:57:30 2015 -0700 ---------------------------------------------------------------------- CHANGES.txt | 1 + .../org/apache/tez/dag/app/launcher/LocalContainerLauncher.java | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tez/blob/664747ed/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index e4d7641..f6583c2 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -7,6 +7,7 @@ Release 0.7.0: Unreleased INCOMPATIBLE CHANGES ALL CHANGES: + TEZ-2202. Fix LocalTaskExecutionThread ID to the standard thread numbering. TEZ-2059. Remove TaskEventHandler in TestDAGImpl TEZ-2191. Simulation improvements to MockDAGAppMaster TEZ-2195. TestTezJobs::testInvalidQueueSubmission/testInvalidQueueSubmissionToSession http://git-wip-us.apache.org/repos/asf/tez/blob/664747ed/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/LocalContainerLauncher.java ---------------------------------------------------------------------- diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/LocalContainerLauncher.java b/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/LocalContainerLauncher.java index 13601fe..d94849a 100644 --- a/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/LocalContainerLauncher.java +++ b/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/LocalContainerLauncher.java @@ -126,7 +126,7 @@ public class LocalContainerLauncher extends AbstractService implements TezConfiguration.TEZ_AM_INLINE_TASK_EXECUTION_MAX_TASKS_DEFAULT); Preconditions.checkState(numExecutors >=1, "Must have at least 1 executor"); ExecutorService rawExecutor = Executors.newFixedThreadPool(numExecutors, - new ThreadFactoryBuilder().setDaemon(true).setNameFormat("LocalTaskExecutionThread [%d]") + new ThreadFactoryBuilder().setDaemon(true).setNameFormat("LocalTaskExecutionThread #%d") .build()); this.taskExecutorService = MoreExecutors.listeningDecorator(rawExecutor); }
