From 00186ece72d35eeec0e644c5eb1efc7bbbf18d45 Mon Sep 17 00:00:00 2001
From: alesapin <alesapin@gmail.com>
Date: Wed, 18 Nov 2020 23:36:25 +0300
Subject: [PATCH] Join processing thread

---
 src/Common/ZooKeeper/TestKeeperStorage.cpp | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/src/Common/ZooKeeper/TestKeeperStorage.cpp b/src/Common/ZooKeeper/TestKeeperStorage.cpp
index a374f752b18..262a0b372a2 100644
--- a/src/Common/ZooKeeper/TestKeeperStorage.cpp
+++ b/src/Common/ZooKeeper/TestKeeperStorage.cpp
@@ -528,8 +528,12 @@ void TestKeeperStorage::finalize()
 
         if (shutdown)
             return;
+
         shutdown = true;
+
+        processing_thread.join();
     }
+
     try
     {
         {