YARN-760. NodeManager throws AvroRuntimeException on failed start. Contributed by Niranjan Singh

git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/trunk@1490704 13f79535-47bb-0310-9956-ffa450edef68

hadoop-yarn-project/CHANGES.txt

@@ -10,7 +10,7 @@ Trunk - Unreleased
 
     YARN-84. Use Builder to build RPC server. (Brandon Li via suresh)
 
-  OPTIMAZATIONS
+  OPTIMIZATIONS
 
   BUG FIXES
 
@@ -20,6 +20,30 @@ Trunk - Unreleased
     YARN-597. TestFSDownload fails on Windows due to dependencies on
     tar/gzip/jar tools. (Ivan Mitic via acmurthy) 
 
+Release 2.3.0 - UNRELEASED
+
+  INCOMPATIBLE CHANGES
+
+  NEW FEATURES
+
+  IMPROVEMENTS
+
+  OPTIMIZATIONS
+
+  BUG FIXES
+
+Release 2.2.0 - UNRELEASED
+
+  INCOMPATIBLE CHANGES
+
+  NEW FEATURES
+
+  IMPROVEMENTS
+
+  OPTIMIZATIONS
+
+  BUG FIXES
+
 Release 2.1.0-beta - UNRELEASED
 
   INCOMPATIBLE CHANGES
@@ -450,6 +474,9 @@ Release 2.1.0-beta - UNRELEASED
 
     YARN-761. TestNMClientAsync fails sometimes (Zhijie Shen via bikas)
 
+    YARN-760. NodeManager throws AvroRuntimeException on failed start.
+    (Niranjan Singh via jlowe)
+
   BREAKDOWN OF HADOOP-8562 SUBTASKS AND RELATED JIRAS
 
     YARN-158. Yarn creating package-info.java must not depend on sh.

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/NodeStatusUpdaterImpl.java

@@ -29,7 +29,6 @@ import java.util.Map;
 import java.util.Map.Entry;
 import java.util.Random;
 
-import org.apache.avro.AvroRuntimeException;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.classification.InterfaceAudience.Private;
@@ -163,7 +162,9 @@ public class NodeStatusUpdaterImpl extends AbstractService implements
       super.start();
       startStatusUpdater();
     } catch (Exception e) {
-      throw new AvroRuntimeException(e);
+      String errorMessage = "Unexpected error starting NodeStatusUpdater";
+      LOG.error(errorMessage, e);
+      throw new YarnRuntimeException(e);
     }
   }
 
@@ -186,7 +187,9 @@ public class NodeStatusUpdaterImpl extends AbstractService implements
       statusUpdater.start();
       LOG.info("NodeStatusUpdater thread is reRegistered and restarted");
     } catch (Exception e) {
-      throw new AvroRuntimeException(e);
+      String errorMessage = "Unexpected error rebooting NodeStatusUpdater";
+      LOG.error(errorMessage, e);
+      throw new YarnRuntimeException(e);
     }
   }