FLUME-1421. PollableSourceRunner should name it's thread. (Brock Noland via Hari Shreedharan)
Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/d8d1e581 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/d8d1e581 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/d8d1e581 Branch: refs/heads/cdh-1.2.0+24_intuit Commit: d8d1e581295db13f9ebb7d36adb0c53543928170 Parents: 74c7a46 Author: Hari Shreedharan <[email protected]> Authored: Thu Aug 2 14:14:20 2012 -0700 Committer: Hari Shreedharan <[email protected]> Committed: Fri Sep 7 13:09:20 2012 -0700 ---------------------------------------------------------------------- .../apache/flume/source/PollableSourceRunner.java | 2 ++ 1 files changed, 2 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/d8d1e581/flume-ng-core/src/main/java/org/apache/flume/source/PollableSourceRunner.java ---------------------------------------------------------------------- diff --git a/flume-ng-core/src/main/java/org/apache/flume/source/PollableSourceRunner.java b/flume-ng-core/src/main/java/org/apache/flume/source/PollableSourceRunner.java index d8ef87b..f6c64b3 100644 --- a/flume-ng-core/src/main/java/org/apache/flume/source/PollableSourceRunner.java +++ b/flume-ng-core/src/main/java/org/apache/flume/source/PollableSourceRunner.java @@ -80,6 +80,8 @@ public class PollableSourceRunner extends SourceRunner { runner.shouldStop = shouldStop; runnerThread = new Thread(runner); + runnerThread.setName(getClass().getSimpleName() + "-" + + source.getClass().getSimpleName() + "-" + source.getName()); runnerThread.start(); lifecycleState = LifecycleState.START;
