https://clickhouse-test-reports.s3.yandex.net/19868/c39ee3f58c85de0f2a7b609377e2f138305dc745/fuzzer_debug/report.html#fail1
{
        if (file_indices.empty())
            return;
        CurrentMetrics::Increment metric_increment{CurrentMetrics::DistributedSend};
        if (!recovered)
        {
            
            
            
            
            
            String tmp_file{parent.current_batch_file_path + ".tmp"};
            auto dir_sync_guard = getDirectorySyncGuard(dir_fsync, parent.disk, parent.relative_path);
            if (Poco::File{tmp_file}.exists())
                LOG_ERROR(parent.log, "Temporary file {} exists. Unclean shutdown?", backQuote(tmp_file));
            {
                WriteBufferFromFile out{tmp_file, O_WRONLY | O_TRUNC | O_CREAT};
                writeText(out);
                out.finalize();
                if (fsync)
                    out.sync();
            }
            Poco::File{tmp_file}.renameTo(parent.current_batch_file_path);
        }
        auto timeouts = ConnectionTimeouts::getTCPTimeoutsWithFailover(parent.storage.global_context.getSettingsRef());
        auto connection = parent.pool->get(timeouts);
        bool batch_broken = false;
        try
        {