hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From st...@apache.org
Subject svn commit: r1031846 - in /hbase/trunk: CHANGES.txt src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java
Date Fri, 05 Nov 2010 22:11:06 GMT
Author: stack
Date: Fri Nov  5 22:11:05 2010
New Revision: 1031846

URL: http://svn.apache.org/viewvc?rev=1031846&view=rev
Log:
HBASE-3202 Closing a region, if we get a ConnectException, handle it rather than abort

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=1031846&r1=1031845&r2=1031846&view=diff
==============================================================================
--- hbase/trunk/CHANGES.txt (original)
+++ hbase/trunk/CHANGES.txt Fri Nov  5 22:11:05 2010
@@ -650,6 +650,8 @@ Release 0.21.0 - Unreleased
    HBASE-3095  Client needs to reconnect if it expires its zk session
    HBASE-2935  Refactor "Corrupt Data" Tests in TestHLogSplit
                (Alex Newman via Stack)
+   HBASE-3202  Closing a region, if we get a ConnectException, handle
+               it rather than abort
 
 
   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=1031846&r1=1031845&r2=1031846&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 Fri Nov
 5 22:11:05 2010
@@ -23,6 +23,7 @@ import java.io.DataInput;
 import java.io.DataOutput;
 import java.io.IOException;
 import java.lang.Thread.UncaughtExceptionHandler;
+import java.net.ConnectException;
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.HashMap;
@@ -1024,7 +1025,11 @@ public class AssignmentManager extends Z
       LOG.debug("Server " + server + " region CLOSE RPC returned false");
     } catch (NotServingRegionException nsre) {
       // Failed to close, so pass through and reassign
-      LOG.debug("Server " + server + " returned NotServingRegionException");
+      LOG.info("Server " + server + " returned NotServingRegionException");
+    } catch (ConnectException e) {
+      // Failed to connect, so pass through and reassign
+      LOG.info("Server " + server + " returned ConnectException " +
+        e.getMessage());
     } catch (RemoteException re) {
       if (re.unwrapRemoteException() instanceof NotServingRegionException) {
         // Failed to close, so pass through and reassign



Mime
View raw message