https://clickhouse-test-reports.s3.yandex.net/19868/c39ee3f58c85de0f2a7b609377e2f138305dc745/fuzzer_debug/report.html#fail1
std::unique_ptr<RemoteBlockOutputStream> remote;
            bool first = true;
            for (UInt64 file_idx : file_indices)
            {
                auto file_path = file_index_to_path.find(file_idx);
                if (file_path == file_index_to_path.end())
                {
                    LOG_ERROR(parent.log, "Failed to send batch: file with index {} is absent", file_idx);
                    batch_broken = true;
                    break;
                }
                ReadBufferFromFile in(file_path->second);
                const auto & header = readDistributedHeader(in, parent.log);
                if (first)
                {
                    first = false;
                    remote = std::make_unique<RemoteBlockOutputStream>(*connection, timeouts,
                        header.insert_query, header.insert_settings, header.client_info);
                    remote->writePrefix();
                }
                CheckingCompressedReadBuffer checking_in(in);
                remote->writePrepared(checking_in);
            }
            if (remote)
                remote->writeSuffix();
        }
        catch (const Exception & e)
        {
            if (isFileBrokenErrorCode(e.code(), e.isRemoteException()))
            {