@@ -596,6 +596,9 @@ class BPServiceActor implements Runnable {
if (bpThread != null) {
bpThread.interrupt();
}
+ if (commandProcessingThread != null) {
+ commandProcessingThread.interrupt();
+ }
//This must be called only by blockPoolManager