https://clickhouse-test-reports.s3.yandex.net/19868/c39ee3f58c85de0f2a7b609377e2f138305dc745/fuzzer_debug/report.html#fail1
ReadBufferFromFile in{file_path};
            header = readDistributedHeader(in, log);
            if (header.rows)
            {
                total_rows += header.rows;
                total_bytes += header.bytes;
                sample_block_structure = header.header;
            }
            else
            {
                CompressedReadBuffer decompressing_in(in);
                NativeBlockInputStream block_in(decompressing_in, DBMS_TCP_PROTOCOL_VERSION);
                block_in.readPrefix();
                while (Block block = block_in.read())
                {
                    total_rows += block.rows();
                    total_bytes += block.bytes();
                    if (sample_block_structure.empty())
                        sample_block_structure = block.cloneEmpty().dumpStructure();
                }
                block_in.readSuffix();
            }
        }
        catch (const Exception & e)
        {
            if (maybeMarkAsBroken(file_path, e))
            {
                tryLogCurrentException(log, "File is marked broken due to");
                continue;