diff --git a/src/transaction.cpp b/src/transaction.cpp
index d6957c5..451e94d 100644
--- a/src/transaction.cpp
+++ b/src/transaction.cpp
@@ -2071,7 +2071,9 @@ int wsrep::transaction::replay(wsrep::unique_lock<wsrep::mutex>& lock)
             wsrep::e_deadlock_error);
         if (is_streaming())
         {
+            lock.unlock();
             client_service_.remove_fragments();
+            lock.lock();
             streaming_context_.cleanup();
         }
         state(lock, s_aborted);