svn commit: r1054837 - in /hbase/trunk: CHANGES.txt src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java

[stack]

Author: stack
Date: Tue Jan  4 00:10:39 2011
New Revision: 1054837

URL: http://svn.apache.org/viewvc?rev=1054837&view=rev
Log:
HBASE-3344 Master aborts after RPC to server that was shutting down

Modified:
    hbase/trunk/CHANGES.txt
    
hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java

Modified: hbase/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/hbase/trunk/CHANGES.txt?rev=1054837&r1=1054836&r2=1054837&view=diff
==============================================================================
--- hbase/trunk/CHANGES.txt (original)
+++ hbase/trunk/CHANGES.txt Tue Jan  4 00:10:39 2011
@@ -811,6 +811,7 @@ Release 0.90.0 - Unreleased
                doing rolling-restart.sh
    HBASE-3383  [0.90RC1] bin/hbase script displays "no such file" warning on
                target/cached_classpath.txt
+   HBASE-3344  Master aborts after RPC to server that was shutting down
 
 
   IMPROVEMENTS

Modified: 
hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java
URL: 
http://svn.apache.org/viewvc/hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java?rev=1054837&r1=1054836&r2=1054837&view=diff
==============================================================================
--- 
hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java 
(original)
+++ 
hbase/trunk/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java 
Tue Jan  4 00:10:39 2011
@@ -1122,6 +1122,10 @@ public class AssignmentManager extends Z
         // Failed to close, so pass through and reassign
         LOG.debug("Server " + server + " returned " + ioe + " for " +
           region.getEncodedName());
+      } else if (ioe instanceof EOFException) {
+        // Failed to close, so pass through and reassign
+        LOG.debug("Server " + server + " returned " + ioe + " for " +
+          region.getEncodedName());
       } else {
         this.master.abort("Remote unexpected exception", ioe);
       }