subject:"hadoop git commit\: YARN\-6015. AsyncDispatcher thread name can be set to improved debugging. Contributed by Ajith S."

[22/50] [abbrv] hadoop git commit: YARN-6015. AsyncDispatcher thread name can be set to improved debugging. Contributed by Ajith S.

2017-01-11 Thread stevel

YARN-6015. AsyncDispatcher thread name can be set to improved debugging. 
Contributed by Ajith S.


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/a59df157
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/a59df157
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/a59df157

Branch: refs/heads/HADOOP-13345
Commit: a59df15757fac7f917cb96fc8fcfeb7017475e4f
Parents: 0203164
Author: Naganarasimha 
Authored: Sat Jan 7 08:11:58 2017 +0530
Committer: Naganarasimha 
Committed: Sat Jan 7 08:11:58 2017 +0530

--
 .../apache/hadoop/yarn/event/AsyncDispatcher.java   | 16 +++-
 .../yarn/nodelabels/CommonNodeLabelsManager.java|  2 +-
 .../hadoop/yarn/server/nodemanager/NodeManager.java |  2 +-
 .../containermanager/ContainerManagerImpl.java  |  2 +-
 .../timelineservice/NMTimelinePublisher.java|  2 +-
 .../server/resourcemanager/ResourceManager.java |  2 +-
 .../ahs/RMApplicationHistoryWriter.java |  2 +-
 .../metrics/AbstractSystemMetricsPublisher.java |  2 +-
 .../resourcemanager/recovery/RMStateStore.java  |  2 +-
 9 files changed, 23 insertions(+), 9 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/hadoop/blob/a59df157/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/event/AsyncDispatcher.java
--
diff --git 
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/event/AsyncDispatcher.java
 
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/event/AsyncDispatcher.java
index a3d306f..913b8ed 100644
--- 
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/event/AsyncDispatcher.java
+++ 
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/event/AsyncDispatcher.java
@@ -74,6 +74,11 @@ public class AsyncDispatcher extends AbstractService 
implements Dispatcher {
   protected final Map eventDispatchers;
   private boolean exitOnDispatchException;
 
+  /**
+   * The thread name for dispatcher.
+   */
+  private String dispatcherThreadName = "AsyncDispatcher event handler";
+
   public AsyncDispatcher() {
 this(new LinkedBlockingQueue());
   }
@@ -84,6 +89,15 @@ public class AsyncDispatcher extends AbstractService 
implements Dispatcher {
 this.eventDispatchers = new HashMap();
   }
 
+  /**
+   * Set a name for this dispatcher thread.
+   * @param dispatcherName name of the dispatcher thread
+   */
+  public AsyncDispatcher(String dispatcherName) {
+this();
+dispatcherThreadName = dispatcherName;
+  }
+
   Runnable createThread() {
 return new Runnable() {
   @Override
@@ -130,7 +144,7 @@ public class AsyncDispatcher extends AbstractService 
implements Dispatcher {
 //start all the components
 super.serviceStart();
 eventHandlingThread = new Thread(createThread());
-eventHandlingThread.setName("AsyncDispatcher event handler");
+eventHandlingThread.setName(dispatcherThreadName);
 eventHandlingThread.start();
   }
 

http://git-wip-us.apache.org/repos/asf/hadoop/blob/a59df157/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/nodelabels/CommonNodeLabelsManager.java
--
diff --git 
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/nodelabels/CommonNodeLabelsManager.java
 
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/nodelabels/CommonNodeLabelsManager.java
index 1a83632..f3f4ba0 100644
--- 
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/nodelabels/CommonNodeLabelsManager.java
+++ 
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/nodelabels/CommonNodeLabelsManager.java
@@ -211,7 +211,7 @@ public class CommonNodeLabelsManager extends 
AbstractService {
   // for UT purpose
   protected void initDispatcher(Configuration conf) {
 // create async handler
-dispatcher = new AsyncDispatcher();
+dispatcher = new AsyncDispatcher("NodeLabelManager dispatcher");
 AsyncDispatcher asyncDispatcher = (AsyncDispatcher) dispatcher;
 asyncDispatcher.init(conf);
 asyncDispatcher.setDrainEventsOnStop();

http://git-wip-us.apache.org/repos/asf/hadoop/blob/a59df157/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/NodeManager.java

hadoop git commit: YARN-6015. AsyncDispatcher thread name can be set to improved debugging. Contributed by Ajith S.

2017-01-10 Thread naganarasimha_gr

Repository: hadoop
Updated Branches:
  refs/heads/branch-2 3190a4ba4 -> ea38256fa


YARN-6015. AsyncDispatcher thread name can be set to improved debugging. 
Contributed by Ajith S.


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/ea38256f
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/ea38256f
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/ea38256f

Branch: refs/heads/branch-2
Commit: ea38256fab9f6986dc0092b72413a0d7626b498f
Parents: 3190a4b
Author: Naganarasimha 
Authored: Tue Jan 10 15:10:54 2017 +0530
Committer: Naganarasimha 
Committed: Tue Jan 10 15:10:54 2017 +0530

--
 .../apache/hadoop/yarn/event/AsyncDispatcher.java   | 16 +++-
 .../yarn/nodelabels/CommonNodeLabelsManager.java|  2 +-
 .../hadoop/yarn/server/nodemanager/NodeManager.java |  2 +-
 .../containermanager/ContainerManagerImpl.java  |  2 +-
 .../server/resourcemanager/ResourceManager.java |  2 +-
 .../ahs/RMApplicationHistoryWriter.java |  2 +-
 .../metrics/SystemMetricsPublisher.java |  2 +-
 .../resourcemanager/recovery/RMStateStore.java  |  2 +-
 8 files changed, 22 insertions(+), 8 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/hadoop/blob/ea38256f/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/event/AsyncDispatcher.java
--
diff --git 
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/event/AsyncDispatcher.java
 
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/event/AsyncDispatcher.java
index 94bfab6..ff472bf 100644
--- 
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/event/AsyncDispatcher.java
+++ 
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/event/AsyncDispatcher.java
@@ -74,6 +74,11 @@ public class AsyncDispatcher extends AbstractService 
implements Dispatcher {
   protected final Map eventDispatchers;
   private boolean exitOnDispatchException;
 
+  /**
+   * The thread name for dispatcher.
+   */
+  private String dispatcherThreadName = "AsyncDispatcher event handler";
+
   public AsyncDispatcher() {
 this(new LinkedBlockingQueue());
   }
@@ -84,6 +89,15 @@ public class AsyncDispatcher extends AbstractService 
implements Dispatcher {
 this.eventDispatchers = new HashMap();
   }
 
+  /**
+   * Set a name for this dispatcher thread.
+   * @param dispatcherName name of the dispatcher thread
+   */
+  public AsyncDispatcher(String dispatcherName) {
+this();
+dispatcherThreadName = dispatcherName;
+  }
+
   Runnable createThread() {
 return new Runnable() {
   @Override
@@ -130,7 +144,7 @@ public class AsyncDispatcher extends AbstractService 
implements Dispatcher {
 //start all the components
 super.serviceStart();
 eventHandlingThread = new Thread(createThread());
-eventHandlingThread.setName("AsyncDispatcher event handler");
+eventHandlingThread.setName(dispatcherThreadName);
 eventHandlingThread.start();
   }
 

http://git-wip-us.apache.org/repos/asf/hadoop/blob/ea38256f/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/nodelabels/CommonNodeLabelsManager.java
--
diff --git 
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/nodelabels/CommonNodeLabelsManager.java
 
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/nodelabels/CommonNodeLabelsManager.java
index 1a83632..f3f4ba0 100644
--- 
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/nodelabels/CommonNodeLabelsManager.java
+++ 
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/nodelabels/CommonNodeLabelsManager.java
@@ -211,7 +211,7 @@ public class CommonNodeLabelsManager extends 
AbstractService {
   // for UT purpose
   protected void initDispatcher(Configuration conf) {
 // create async handler
-dispatcher = new AsyncDispatcher();
+dispatcher = new AsyncDispatcher("NodeLabelManager dispatcher");
 AsyncDispatcher asyncDispatcher = (AsyncDispatcher) dispatcher;
 asyncDispatcher.init(conf);
 asyncDispatcher.setDrainEventsOnStop();

http://git-wip-us.apache.org/repos/asf/hadoop/blob/ea38256f/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/NodeManager.java

[12/21] hadoop git commit: YARN-6015. AsyncDispatcher thread name can be set to improved debugging. Contributed by Ajith S.

2017-01-09 Thread xgong

YARN-6015. AsyncDispatcher thread name can be set to improved debugging. 
Contributed by Ajith S.


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/a59df157
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/a59df157
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/a59df157

Branch: refs/heads/YARN-5734
Commit: a59df15757fac7f917cb96fc8fcfeb7017475e4f
Parents: 0203164
Author: Naganarasimha 
Authored: Sat Jan 7 08:11:58 2017 +0530
Committer: Naganarasimha 
Committed: Sat Jan 7 08:11:58 2017 +0530

--
 .../apache/hadoop/yarn/event/AsyncDispatcher.java   | 16 +++-
 .../yarn/nodelabels/CommonNodeLabelsManager.java|  2 +-
 .../hadoop/yarn/server/nodemanager/NodeManager.java |  2 +-
 .../containermanager/ContainerManagerImpl.java  |  2 +-
 .../timelineservice/NMTimelinePublisher.java|  2 +-
 .../server/resourcemanager/ResourceManager.java |  2 +-
 .../ahs/RMApplicationHistoryWriter.java |  2 +-
 .../metrics/AbstractSystemMetricsPublisher.java |  2 +-
 .../resourcemanager/recovery/RMStateStore.java  |  2 +-
 9 files changed, 23 insertions(+), 9 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/hadoop/blob/a59df157/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/event/AsyncDispatcher.java
--
diff --git 
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/event/AsyncDispatcher.java
 
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/event/AsyncDispatcher.java
index a3d306f..913b8ed 100644
--- 
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/event/AsyncDispatcher.java
+++ 
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/event/AsyncDispatcher.java
@@ -74,6 +74,11 @@ public class AsyncDispatcher extends AbstractService 
implements Dispatcher {
   protected final Map eventDispatchers;
   private boolean exitOnDispatchException;
 
+  /**
+   * The thread name for dispatcher.
+   */
+  private String dispatcherThreadName = "AsyncDispatcher event handler";
+
   public AsyncDispatcher() {
 this(new LinkedBlockingQueue());
   }
@@ -84,6 +89,15 @@ public class AsyncDispatcher extends AbstractService 
implements Dispatcher {
 this.eventDispatchers = new HashMap();
   }
 
+  /**
+   * Set a name for this dispatcher thread.
+   * @param dispatcherName name of the dispatcher thread
+   */
+  public AsyncDispatcher(String dispatcherName) {
+this();
+dispatcherThreadName = dispatcherName;
+  }
+
   Runnable createThread() {
 return new Runnable() {
   @Override
@@ -130,7 +144,7 @@ public class AsyncDispatcher extends AbstractService 
implements Dispatcher {
 //start all the components
 super.serviceStart();
 eventHandlingThread = new Thread(createThread());
-eventHandlingThread.setName("AsyncDispatcher event handler");
+eventHandlingThread.setName(dispatcherThreadName);
 eventHandlingThread.start();
   }
 

http://git-wip-us.apache.org/repos/asf/hadoop/blob/a59df157/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/nodelabels/CommonNodeLabelsManager.java
--
diff --git 
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/nodelabels/CommonNodeLabelsManager.java
 
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/nodelabels/CommonNodeLabelsManager.java
index 1a83632..f3f4ba0 100644
--- 
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/nodelabels/CommonNodeLabelsManager.java
+++ 
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/nodelabels/CommonNodeLabelsManager.java
@@ -211,7 +211,7 @@ public class CommonNodeLabelsManager extends 
AbstractService {
   // for UT purpose
   protected void initDispatcher(Configuration conf) {
 // create async handler
-dispatcher = new AsyncDispatcher();
+dispatcher = new AsyncDispatcher("NodeLabelManager dispatcher");
 AsyncDispatcher asyncDispatcher = (AsyncDispatcher) dispatcher;
 asyncDispatcher.init(conf);
 asyncDispatcher.setDrainEventsOnStop();

http://git-wip-us.apache.org/repos/asf/hadoop/blob/a59df157/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/NodeManager.java
--

hadoop git commit: YARN-6015. AsyncDispatcher thread name can be set to improved debugging. Contributed by Ajith S.

2017-01-06 Thread naganarasimha_gr

Repository: hadoop
Updated Branches:
  refs/heads/trunk 020316458 -> a59df1575


YARN-6015. AsyncDispatcher thread name can be set to improved debugging. 
Contributed by Ajith S.


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/a59df157
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/a59df157
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/a59df157

Branch: refs/heads/trunk
Commit: a59df15757fac7f917cb96fc8fcfeb7017475e4f
Parents: 0203164
Author: Naganarasimha 
Authored: Sat Jan 7 08:11:58 2017 +0530
Committer: Naganarasimha 
Committed: Sat Jan 7 08:11:58 2017 +0530

--
 .../apache/hadoop/yarn/event/AsyncDispatcher.java   | 16 +++-
 .../yarn/nodelabels/CommonNodeLabelsManager.java|  2 +-
 .../hadoop/yarn/server/nodemanager/NodeManager.java |  2 +-
 .../containermanager/ContainerManagerImpl.java  |  2 +-
 .../timelineservice/NMTimelinePublisher.java|  2 +-
 .../server/resourcemanager/ResourceManager.java |  2 +-
 .../ahs/RMApplicationHistoryWriter.java |  2 +-
 .../metrics/AbstractSystemMetricsPublisher.java |  2 +-
 .../resourcemanager/recovery/RMStateStore.java  |  2 +-
 9 files changed, 23 insertions(+), 9 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/hadoop/blob/a59df157/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/event/AsyncDispatcher.java
--
diff --git 
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/event/AsyncDispatcher.java
 
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/event/AsyncDispatcher.java
index a3d306f..913b8ed 100644
--- 
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/event/AsyncDispatcher.java
+++ 
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/event/AsyncDispatcher.java
@@ -74,6 +74,11 @@ public class AsyncDispatcher extends AbstractService 
implements Dispatcher {
   protected final Map eventDispatchers;
   private boolean exitOnDispatchException;
 
+  /**
+   * The thread name for dispatcher.
+   */
+  private String dispatcherThreadName = "AsyncDispatcher event handler";
+
   public AsyncDispatcher() {
 this(new LinkedBlockingQueue());
   }
@@ -84,6 +89,15 @@ public class AsyncDispatcher extends AbstractService 
implements Dispatcher {
 this.eventDispatchers = new HashMap();
   }
 
+  /**
+   * Set a name for this dispatcher thread.
+   * @param dispatcherName name of the dispatcher thread
+   */
+  public AsyncDispatcher(String dispatcherName) {
+this();
+dispatcherThreadName = dispatcherName;
+  }
+
   Runnable createThread() {
 return new Runnable() {
   @Override
@@ -130,7 +144,7 @@ public class AsyncDispatcher extends AbstractService 
implements Dispatcher {
 //start all the components
 super.serviceStart();
 eventHandlingThread = new Thread(createThread());
-eventHandlingThread.setName("AsyncDispatcher event handler");
+eventHandlingThread.setName(dispatcherThreadName);
 eventHandlingThread.start();
   }
 

http://git-wip-us.apache.org/repos/asf/hadoop/blob/a59df157/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/nodelabels/CommonNodeLabelsManager.java
--
diff --git 
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/nodelabels/CommonNodeLabelsManager.java
 
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/nodelabels/CommonNodeLabelsManager.java
index 1a83632..f3f4ba0 100644
--- 
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/nodelabels/CommonNodeLabelsManager.java
+++ 
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/nodelabels/CommonNodeLabelsManager.java
@@ -211,7 +211,7 @@ public class CommonNodeLabelsManager extends 
AbstractService {
   // for UT purpose
   protected void initDispatcher(Configuration conf) {
 // create async handler
-dispatcher = new AsyncDispatcher();
+dispatcher = new AsyncDispatcher("NodeLabelManager dispatcher");
 AsyncDispatcher asyncDispatcher = (AsyncDispatcher) dispatcher;
 asyncDispatcher.init(conf);
 asyncDispatcher.setDrainEventsOnStop();

[22/50] [abbrv] hadoop git commit: YARN-6015. AsyncDispatcher thread name can be set to improved debugging. Contributed by Ajith S.

hadoop git commit: YARN-6015. AsyncDispatcher thread name can be set to improved debugging. Contributed by Ajith S.

[12/21] hadoop git commit: YARN-6015. AsyncDispatcher thread name can be set to improved debugging. Contributed by Ajith S.

hadoop git commit: YARN-6015. AsyncDispatcher thread name can be set to improved debugging. Contributed by Ajith S.

4 matches

Site Navigation

Mail list logo

Footer information