https://clickhouse-test-reports.s3.yandex.net/19868/c39ee3f58c85de0f2a7b609377e2f138305dc745/fuzzer_debug/report.html#fail1
job.stream->writePrefix();
            }
            CurrentMetrics::Increment metric_increment{CurrentMetrics::DistributedSend};
            job.stream->write(shard_block);
        }
        else 
        {
            if (!job.stream)
            {
                
                job.local_context = std::make_unique<Context>(context);
                
                
                
                
                
                
                auto copy_query_ast = query_ast->clone();
                InterpreterInsertQuery interp(copy_query_ast, *job.local_context);
                auto block_io = interp.execute();
                job.stream = block_io.out;
                job.stream->writePrefix();
            }
            writeBlockConvert(job.stream, shard_block, shard_info.getLocalNodeCount());
        }
        job.blocks_written += 1;
        job.rows_written += shard_block.rows();
    };
}
void DistributedBlockOutputStream::writeSync(const Block & block)