diff --git a/src/DataStreams/PushingToViewsBlockOutputStream.cpp b/src/DataStreams/PushingToViewsBlockOutputStream.cpp
index 5f82104d914..1686e4ee0e2 100644
--- a/src/DataStreams/PushingToViewsBlockOutputStream.cpp
+++ b/src/DataStreams/PushingToViewsBlockOutputStream.cpp
@@ -271,7 +271,9 @@ public:
 
     void consume(Chunk chunk) override
     {
+        Progress local_progress(chunk.getNumRows(), chunk.bytes(), 0);
         StorageLiveView::writeIntoLiveView(live_view, getHeader().cloneWithColumns(chunk.detachColumns()), context);
+        CurrentThread::updateProgressIn(local_progress);
     }
 
 private: