rmv from system.exports

Author: arthurpassos

src/Storages/MergeTree/ExportList.cpp

@@ -63,4 +63,12 @@ UInt64 ExportsListElement::getPeakMemoryUsage() const
     return thread_group->memory_tracker.getPeak();
 }
 
+void ExportsList::remove(const StorageID & source_table_id, const StorageID & destination_table_id, const String & part_name)
+{
+    std::erase_if(entries, [source_table_id, destination_table_id, part_name](const auto & entry)
+    {
+        return entry.source_table_id == source_table_id && entry.destination_table_id == destination_table_id && entry.part_name == part_name;
+    });
+}
+
 }

src/Storages/MergeTree/ExportList.h

@@ -83,6 +83,8 @@ class ExportsList final : public BackgroundProcessList<ExportsListElement, Expor
     ExportsList()
         : Parent(CurrentMetrics::Export)
     {}
+
+    void remove(const StorageID & source_table_id, const StorageID & destination_table_id, const String & part_name);
 };
 
 using ExportsListEntry = BackgroundProcessListEntry<ExportsListElement, ExportInfo>;

src/Storages/MergeTree/MergeTreeData.cpp

@@ -6458,6 +6458,8 @@ void MergeTreeData::killExportPart(const String & query_id)
         {
             if (manifest.task)
                 manifest.task->cancel();
+
+            getContext()->getExportsList().remove(getStorageID(), manifest.destination_storage_id, manifest.data_part->name);
             return true;
         }
         return false;