diff --git a/src/Storages/MergeTree/ReplicatedFetchList.cpp b/src/Storages/MergeTree/ReplicatedFetchList.cpp
index 63971a7b2e1..82bc8ae21e0 100644
--- a/src/Storages/MergeTree/ReplicatedFetchList.cpp
+++ b/src/Storages/MergeTree/ReplicatedFetchList.cpp
@@ -1,10 +1,10 @@
 #include <Storages/MergeTree/ReplicatedFetchList.h>
 #include <Common/CurrentMetrics.h>
 #include <common/getThreadId.h>
-#include <Common/CurrentThread.h>
 
 namespace DB
 {
+
 ReplicatedFetchListElement::ReplicatedFetchListElement(
     const std::string & database_, const std::string & table_,
     const std::string & partition_id_, const std::string & result_part_name_,
@@ -26,7 +26,6 @@ ReplicatedFetchListElement::ReplicatedFetchListElement(
 {
 }
 
-
 ReplicatedFetchInfo ReplicatedFetchListElement::getInfo() const
 {
     ReplicatedFetchInfo res;
diff --git a/src/Storages/MergeTree/ReplicatedFetchList.h b/src/Storages/MergeTree/ReplicatedFetchList.h
index 670e1fb984a..ed134de3f2c 100644
--- a/src/Storages/MergeTree/ReplicatedFetchList.h
+++ b/src/Storages/MergeTree/ReplicatedFetchList.h
@@ -50,21 +50,22 @@ struct ReplicatedFetchListElement : private boost::noncopyable
     const std::string result_part_name;
     const std::string result_part_path;
 
-    std::string source_replica_path;
-    std::string source_replica_hostname;
-    UInt16 source_replica_port;
-    std::string interserver_scheme;
-    std::string uri;
+    const std::string source_replica_path;
+    const std::string source_replica_hostname;
+    const UInt16 source_replica_port;
+    const std::string interserver_scheme;
+    const std::string uri;
 
     const UInt8 to_detached;
 
     Stopwatch watch;
     std::atomic<Float64> progress{};
-    std::atomic<bool> is_cancelled{};
+    /// How many bytes already read
     std::atomic<UInt64> bytes_read_compressed{};
-    UInt64 total_size_bytes_compressed{};
+    /// Total bytes to read
+    const UInt64 total_size_bytes_compressed{};
 
-    UInt64 thread_id;
+    const UInt64 thread_id;
 
     ReplicatedFetchListElement(
         const std::string & database_, const std::string & table_,
@@ -78,6 +79,7 @@ struct ReplicatedFetchListElement : private boost::noncopyable
 
 using ReplicatedFetchListEntry = BackgroundProcessListEntry<ReplicatedFetchListElement, ReplicatedFetchInfo>;
 
+/// List of currently processing replicated fetches
 class ReplicatedFetchList final : public BackgroundProcessList<ReplicatedFetchListElement, ReplicatedFetchInfo>
 {
 private: