https://s3.amazonaws.com/clickhouse-test-reports/43986/7249ad407a0824d8c7651d8e03d4e68e1dea0813/stress_test__msan_.html
{
        LOG_WARNING(log, "Directory {} already exists, probably result of a failed fetch. Will remove it before fetching part.",
            data_part_storage->getFullPath());
        
        
        
        
        
        bool keep_shared = disk->supportZeroCopyReplication() && data_settings->allow_remote_fs_zero_copy_replication;
        data_part_storage->removeSharedRecursive(keep_shared);
    }
    data_part_storage->createDirectories();
    SyncGuardPtr sync_guard;
    if (data.getSettings()->fsync_part_directory)
        sync_guard = data_part_storage->getDirectorySyncGuard();
    CurrentMetrics::Increment metric_increment{CurrentMetrics::ReplicatedFetch};
    for (size_t i = 0; i < projections; ++i)
    {
        String projection_name;
        readStringBinary(projection_name, in);
        MergeTreeData::DataPart::Checksums projection_checksum;
        auto projection_part_storage = data_part_storage->getProjection(projection_name + ".proj");
        projection_part_storage->createDirectories();
        downloadBaseOrProjectionPartToDisk(
            replica_path, projection_part_storage, sync, in, projection_checksum, throttler);
        checksums.addFile(
            projection_name + ".proj", projection_checksum.getTotalSizeOnDisk(), projection_checksum.getTotalChecksumUInt128());
    }
    
    downloadBaseOrProjectionPartToDisk(replica_path, data_part_storage, sync, in, checksums, throttler);