You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by yu...@apache.org on 2015/05/04 17:02:06 UTC
cassandra git commit: Fix threadpool in RepairSession is not shutdown
on failure
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 <ko...@gmail.com>
Authored: Mon May 4 09:58:41 2015 -0500
Committer: Yuki Morishita <yu...@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);
}
});
}