From 2ae9490a681d3d522dd30e96b9f36b2d638ffd10 Mon Sep 17 00:00:00 2001
From: Alexey Korepanov <alexey.korepanov@clickhouse.com>
Date: Sun, 7 Jul 2024 21:22:02 +0200
Subject: [PATCH] Fix progress rows and bytes read

---
 .../Formats/Impl/JSONCompactWithProgressRowOutputFormat.cpp  | 5 ++---
 .../Formats/Impl/JSONCompactWithProgressRowOutputFormat.h    | 1 -
 2 files changed, 2 insertions(+), 4 deletions(-)

diff --git a/src/Processors/Formats/Impl/JSONCompactWithProgressRowOutputFormat.cpp b/src/Processors/Formats/Impl/JSONCompactWithProgressRowOutputFormat.cpp
index 7a19b56d0ca..d72a6556c2b 100644
--- a/src/Processors/Formats/Impl/JSONCompactWithProgressRowOutputFormat.cpp
+++ b/src/Processors/Formats/Impl/JSONCompactWithProgressRowOutputFormat.cpp
@@ -81,11 +81,11 @@ void JSONCompactWithProgressRowOutputFormat::writeExtremesElement(const char * t
 
 void JSONCompactWithProgressRowOutputFormat::onProgress(const Progress & value)
 {
-    progress.incrementPiecewiseAtomically(value);
+    statistics.progress.incrementPiecewiseAtomically(value);
     String progress_line;
     WriteBufferFromString buf(progress_line);
     writeCString("{\"progress\":", buf);
-    progress.writeJSON(buf);
+    statistics.progress.writeJSON(buf);
     writeCString("}\n", buf);
     buf.finalize();
     std::lock_guard lock(progress_lines_mutex);
@@ -127,7 +127,6 @@ void JSONCompactWithProgressRowOutputFormat::finalizeImpl()
         settings.write_statistics && exception_message.empty(),
         *ostr);
 
-    exception_message = "Test exception message.";
     if (!exception_message.empty())
     {
         writeCString("\n", *ostr);
diff --git a/src/Processors/Formats/Impl/JSONCompactWithProgressRowOutputFormat.h b/src/Processors/Formats/Impl/JSONCompactWithProgressRowOutputFormat.h
index 0c7e6b295e8..669e342c583 100644
--- a/src/Processors/Formats/Impl/JSONCompactWithProgressRowOutputFormat.h
+++ b/src/Processors/Formats/Impl/JSONCompactWithProgressRowOutputFormat.h
@@ -46,7 +46,6 @@ private:
     void finalizeImpl() override;
 
 
-    Progress progress;
     std::vector<String> progress_lines;
     std::mutex progress_lines_mutex;
     /// To not lock mutex and check progress_lines every row,