diff --git a/src/Processors/Formats/Impl/ParquetBlockInputFormat.cpp b/src/Processors/Formats/Impl/ParquetBlockInputFormat.cpp
index e35d53dc4f4..7faa7300416 100644
--- a/src/Processors/Formats/Impl/ParquetBlockInputFormat.cpp
+++ b/src/Processors/Formats/Impl/ParquetBlockInputFormat.cpp
@@ -673,6 +673,15 @@ void ParquetBlockInputFormat::scheduleMoreWorkIfNeeded(std::optional<size_t> row
     }
 }
 
+Chunk ParquetBlockInputFormat::generate()
+{
+    auto res = IInputFormat::generate();
+    if (!res)
+        LOG_INFO(&Poco::Logger::get("ParquetBlockInputFormat"), "{} ms consumed by reading parquet file", consumed_nanosecs / 1e6);
+
+    return res;
+}
+
 Chunk ParquetBlockInputFormat::read()
 {
     initializeIfNeeded();
@@ -683,6 +692,8 @@ Chunk ParquetBlockInputFormat::read()
     if (need_only_count)
         return getChunkForCount(row_group_batches[row_group_batches_completed++].total_rows);
 
+    Stopwatch watch(CLOCK_MONOTONIC);
+    SCOPE_EXIT({ consumed_nanosecs += watch.elapsedNanoseconds(); });
     std::unique_lock lock(mutex);
 
     while (true)
diff --git a/src/Processors/Formats/Impl/ParquetBlockInputFormat.h b/src/Processors/Formats/Impl/ParquetBlockInputFormat.h
index a737c695fd6..a94637da942 100644
--- a/src/Processors/Formats/Impl/ParquetBlockInputFormat.h
+++ b/src/Processors/Formats/Impl/ParquetBlockInputFormat.h
@@ -65,6 +65,8 @@ public:
 
     size_t getApproxBytesReadForChunk() const override { return previous_approx_bytes_read_for_chunk; }
 
+    Chunk generate() override;
+
 private:
     Chunk read() override;
 
@@ -286,6 +288,8 @@ private:
     std::exception_ptr background_exception = nullptr;
     std::atomic<int> is_stopped{0};
     bool is_initialized = false;
+
+    UInt64 consumed_nanosecs = 0;
 };
 
 class ParquetSchemaReader : public ISchemaReader