Updated Branches: refs/heads/trunk d389b50c2 -> eaee4225a
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/eaee4225 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/eaee4225 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/eaee4225 Branch: refs/heads/trunk Commit: eaee4225a0cc8fa4c22f40cf6a47f282c3498865 Parents: d389b50 Author: Hari Shreedharan <[email protected]> Authored: Thu Aug 2 14:14:20 2012 -0700 Committer: Hari Shreedharan <[email protected]> Committed: Thu Aug 2 14:14: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/eaee4225/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;
