diff --git a/src/Interpreters/AsynchronousInsertQueue.cpp b/src/Interpreters/AsynchronousInsertQueue.cpp index 5e39e4a6f44..975a331dd88 100644 --- a/src/Interpreters/AsynchronousInsertQueue.cpp +++ b/src/Interpreters/AsynchronousInsertQueue.cpp @@ -592,7 +592,7 @@ void AsynchronousInsertQueue::finishWithException( { ProfileEvents::increment(ProfileEvents::FailedAsyncInsertQuery, entries.size()); tryLogCurrentException("AsynchronousInsertQueue", fmt::format("Failed insertion for query '{}'", queryToString(query))); - + for (const auto & entry : entries) { if (!entry->isFinished())