hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t...@apache.org
Subject svn commit: r1539476 - in /hadoop/common/branches/branch-1: CHANGES.txt src/mapred/org/apache/hadoop/mapred/JobEndNotifier.java
Date Wed, 06 Nov 2013 22:15:26 GMT
Author: tucu
Date: Wed Nov  6 22:15:25 2013
New Revision: 1539476

URL: http://svn.apache.org/r1539476
Log:
MAPREDUCE-5609. Add debug log message when sending job end notification. (rkanter via tucu)

Modified:
    hadoop/common/branches/branch-1/CHANGES.txt
    hadoop/common/branches/branch-1/src/mapred/org/apache/hadoop/mapred/JobEndNotifier.java

Modified: hadoop/common/branches/branch-1/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-1/CHANGES.txt?rev=1539476&r1=1539475&r2=1539476&view=diff
==============================================================================
--- hadoop/common/branches/branch-1/CHANGES.txt (original)
+++ hadoop/common/branches/branch-1/CHANGES.txt Wed Nov  6 22:15:25 2013
@@ -46,6 +46,9 @@ Release 1.3.0 - unreleased
     HDFS-5367. Restoring namenode storage locks namenode due to unnecessary
     fsimage write. (Jonh Zhao via suresh)
 
+    MAPREDUCE-5609. Add debug log message when sending job end notification. 
+    (rkanter via tucu)
+
   BUG FIXES
 
     HADOOP-9863. Backport HADOOP-8686 to support BigEndian on ppc64. 

Modified: hadoop/common/branches/branch-1/src/mapred/org/apache/hadoop/mapred/JobEndNotifier.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-1/src/mapred/org/apache/hadoop/mapred/JobEndNotifier.java?rev=1539476&r1=1539475&r2=1539476&view=diff
==============================================================================
--- hadoop/common/branches/branch-1/src/mapred/org/apache/hadoop/mapred/JobEndNotifier.java
(original)
+++ hadoop/common/branches/branch-1/src/mapred/org/apache/hadoop/mapred/JobEndNotifier.java
Wed Nov  6 22:15:25 2013
@@ -49,6 +49,7 @@ public class JobEndNotifier {
           public void run() {
             try {
               while (running) {
+                LOG.debug("Pending notifications: " + queue.size());
                 sendNotification(queue.take());
               }
             }
@@ -61,6 +62,7 @@ public class JobEndNotifier {
 
           private void sendNotification(JobEndStatusInfo notification) {
             try {
+              LOG.debug("Sending notification [" + notification + "]");
               int code = httpNotification(notification.getUri(),
                   notification.getTimeout());
               if (code != 200) {



Mime
View raw message