cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From yu...@apache.org
Subject cassandra git commit: Fix threadpool in RepairSession is not shutdown on failure
Date Mon, 04 May 2015 15:02:06 GMT
Repository: cassandra
Updated Branches:
  refs/heads/trunk d9836e0ef -> 7223ec025


Fix threadpool in RepairSession is not shutdown on failure

patch by Sankalp Kohli; reviewed by yukim for CASSANDRA-9260


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/7223ec02
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/7223ec02
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/7223ec02

Branch: refs/heads/trunk
Commit: 7223ec025b749b57d7610aef5e991f151d73b157
Parents: d9836e0
Author: Sankalp Kohli <kohlisankalp@gmail.com>
Authored: Mon May 4 09:58:41 2015 -0500
Committer: Yuki Morishita <yukim@apache.org>
Committed: Mon May 4 09:58:41 2015 -0500

----------------------------------------------------------------------
 src/java/org/apache/cassandra/repair/RepairSession.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/7223ec02/src/java/org/apache/cassandra/repair/RepairSession.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/repair/RepairSession.java b/src/java/org/apache/cassandra/repair/RepairSession.java
index 9762159..70bfaa6 100644
--- a/src/java/org/apache/cassandra/repair/RepairSession.java
+++ b/src/java/org/apache/cassandra/repair/RepairSession.java
@@ -276,7 +276,7 @@ public class RepairSession extends AbstractFuture<RepairSessionResult>
implement
             {
                 logger.error(String.format("[repair #%s] Session completed with the following
error", getId()), t);
                 Tracing.traceRepair("Session completed with the following error: {}", t);
-                setException(t);
+                forceShutdown(t);
             }
         });
     }


Mime
View raw message