hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jeffr...@apache.org
Subject svn commit: r1517067 - /hbase/branches/0.95/hbase-server/src/main/java/org/apache/hadoop/hbase/procedure/ProcedureMember.java
Date Fri, 23 Aug 2013 21:50:32 GMT
Author: jeffreyz
Date: Fri Aug 23 21:50:32 2013
New Revision: 1517067

URL: http://svn.apache.org/r1517067
Log:
HBASE-9324: TestProcedureMember#testMemberCommitException, testSimpleRun & testMemberCommitCommsFailure
are flaky on Suse OS

Modified:
    hbase/branches/0.95/hbase-server/src/main/java/org/apache/hadoop/hbase/procedure/ProcedureMember.java

Modified: hbase/branches/0.95/hbase-server/src/main/java/org/apache/hadoop/hbase/procedure/ProcedureMember.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.95/hbase-server/src/main/java/org/apache/hadoop/hbase/procedure/ProcedureMember.java?rev=1517067&r1=1517066&r2=1517067&view=diff
==============================================================================
--- hbase/branches/0.95/hbase-server/src/main/java/org/apache/hadoop/hbase/procedure/ProcedureMember.java
(original)
+++ hbase/branches/0.95/hbase-server/src/main/java/org/apache/hadoop/hbase/procedure/ProcedureMember.java
Fri Aug 23 21:50:32 2013
@@ -159,12 +159,15 @@ public class ProcedureMember implements 
     // kick off the subprocedure
     Future<Void> future = null;
     try {
-      future = this.pool.submit(subproc);
       synchronized (subprocs) {
         subprocs.put(procName, subproc);
       }
+      future = this.pool.submit(subproc);
       return true;
     } catch (RejectedExecutionException e) {
+      synchronized (subprocs) {
+        subprocs.remove(procName);
+      }
       // the thread pool is full and we can't run the subprocedure
       String msg = "Subprocedure pool is full!";
       subproc.cancel(msg, e.getCause());



Mime
View raw message