https://clickhouse-test-reports.s3.yandex.net/19868/c39ee3f58c85de0f2a7b609377e2f138305dc745/fuzzer_debug/report.html#fail1
{
    const Settings & settings = context.getSettingsRef();
    const auto & shards_info = cluster->getShardsInfo();
    bool random_shard_insert = settings.insert_distributed_one_random_shard && !storage.has_sharding_key;
    size_t start = 0;
    size_t end = shards_info.size();
    if (random_shard_insert)
    {
        start = storage.getRandomShardIndex(shards_info);
        end = start + 1;
    }
    size_t num_shards = end - start;
    if (!pool)
    {
        
        initWritingJobs(block, start, end);
        pool.emplace(remote_jobs_count + local_jobs_count);
        if (!throttler && (settings.max_network_bandwidth || settings.max_network_bytes))
        {
            throttler = std::make_shared<Throttler>(settings.max_network_bandwidth, settings.max_network_bytes,
                                                    "Network bandwidth limit for a query exceeded.");
        }
        watch.restart();
    }
    watch_current_block.restart();
    if (num_shards > 1)
    {
        auto current_selector = createSelector(block);
        
        for (size_t shard_index : ext::range(0, num_shards))