diff --git a/src/Interpreters/AsynchronousInsertQueue.cpp b/src/Interpreters/AsynchronousInsertQueue.cpp
index 969c62f0d2d..13df614fff5 100644
--- a/src/Interpreters/AsynchronousInsertQueue.cpp
+++ b/src/Interpreters/AsynchronousInsertQueue.cpp
@@ -360,11 +360,10 @@ try
     for (const auto & entry : data->entries)
     {
         buffer = std::make_unique<ReadBufferFromString>(entry->bytes);
-
-        format->resetParser();
         format->setReadBuffer(*buffer);
         current_entry = entry;
         total_rows += executor.execute();
+        format->resetParser();
     }
 
     auto chunk = Chunk(executor.getResultColumns(), total_rows);