MAPREDUCE-6748. Enhance logging for Cluster.java around InetSocketAddress 
(Vrushali C via Varun Saxena)


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

Branch: refs/heads/YARN-3368
Commit: 6529fe934546395cff73e4246f12f2dda13d2131
Parents: 4d3af47
Author: Varun Saxena <[email protected]>
Authored: Mon Aug 8 21:49:54 2016 +0530
Committer: Varun Saxena <[email protected]>
Committed: Mon Aug 8 21:49:54 2016 +0530

----------------------------------------------------------------------
 .../src/main/java/org/apache/hadoop/mapreduce/Cluster.java       | 4 ++++
 1 file changed, 4 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hadoop/blob/6529fe93/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/Cluster.java
----------------------------------------------------------------------
diff --git 
a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/Cluster.java
 
b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/Cluster.java
index 6ca918d..dcce2aa 100644
--- 
a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/Cluster.java
+++ 
b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/Cluster.java
@@ -106,6 +106,10 @@ public class Cluster {
         "Cannot initialize Cluster. Please check your configuration for "
             + MRConfig.FRAMEWORK_NAME
             + " and the correspond server addresses.");
+    if (jobTrackAddr != null) {
+      LOG.info(
+          "Initializing cluster for Job Tracker=" + jobTrackAddr.toString());
+    }
     for (ClientProtocolProvider provider : providerList) {
       LOG.debug("Trying ClientProtocolProvider : "
           + provider.getClass().getName());


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to