From 6a32a949e6d23b87295e4f59202cfeca752376ed Mon Sep 17 00:00:00 2001
From: Nikolai Kochetov <nik-kochetov@yandex-team.ru>
Date: Tue, 14 Sep 2021 17:22:26 +0300
Subject: [PATCH] Fix read_rows for live view.

---
 src/DataStreams/PushingToViewsBlockOutputStream.cpp | 2 ++
 1 file changed, 2 insertions(+)

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: