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) {
