From d190ee8113ae6eae7d77850e884fae7e56c65924 Mon Sep 17 00:00:00 2001 From: Alexander Tokmakov Date: Wed, 20 Mar 2024 19:19:30 +0100 Subject: [PATCH] Update AsynchronousInsertQueue.h --- src/Interpreters/AsynchronousInsertQueue.h | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/Interpreters/AsynchronousInsertQueue.h b/src/Interpreters/AsynchronousInsertQueue.h index 1a4678e3a7d..a8ee064877d 100644 --- a/src/Interpreters/AsynchronousInsertQueue.h +++ b/src/Interpreters/AsynchronousInsertQueue.h @@ -63,6 +63,8 @@ public: PushResult pushQueryWithBlock(ASTPtr query, Block block, ContextPtr query_context); size_t getPoolSize() const { return pool_size; } + /// This method should be called manually because it's not flushed automatically in dtor + /// because all tables may be already unloaded when we destroy AsynchronousInsertQueue void flushAndShutdown(); private: