https://clickhouse-test-reports.s3.yandex.net/19868/c39ee3f58c85de0f2a7b609377e2f138305dc745/fuzzer_debug/report.html#fail1
{
    if (should_batch_inserts)
    {
        processFilesWithBatching(files);
    }
    else
    {
        for (const auto & file : files)
        {
            if (quit)
                return true;
            processFile(file.second);
        }
    }
    return true;
}
void StorageDistributedDirectoryMonitor::processFile(const std::string & file_path)
{
    LOG_TRACE(log, "Started processing `{}`", file_path);
    auto timeouts = ConnectionTimeouts::getTCPTimeoutsWithFailover(storage.global_context.getSettingsRef());
    try
    {
        CurrentMetrics::Increment metric_increment{CurrentMetrics::DistributedSend};
        ReadBufferFromFile in(file_path);
        const auto & header = readDistributedHeader(in, log);
        auto connection = pool->get(timeouts, &header.insert_settings);
        RemoteBlockOutputStream remote{*connection, timeouts,