commit | 84edc08ccc5b0cfc7112fb89ab3ebc343ab9fcb9 | [log] [tgz] |
---|---|---|
author | poorna <poorna@apache.org> | Wed Apr 25 16:58:22 2018 -0700 |
committer | poorna <poorna@apache.org> | Tue May 01 16:50:07 2018 -0700 |
tree | 007c61a6f43aaad379fd740ff940964ebeca0cc2 | |
parent | fab3aa352237d0191a7f655173d092b54e56106d [diff] |
TEPHRA-271 Wait for the refresh thread to stop during shutdown to prevent race conditions Signed-off-by: poorna <poorna@apache.org>
diff --git a/tephra-core/src/main/java/org/apache/tephra/coprocessor/TransactionStateCache.java b/tephra-core/src/main/java/org/apache/tephra/coprocessor/TransactionStateCache.java index a80ce61..ac329f9 100644 --- a/tephra-core/src/main/java/org/apache/tephra/coprocessor/TransactionStateCache.java +++ b/tephra-core/src/main/java/org/apache/tephra/coprocessor/TransactionStateCache.java
@@ -78,6 +78,7 @@ protected void shutDown() throws Exception { if (refreshService != null) { refreshService.interrupt(); + refreshService.join(1000); } if (storage != null) {