Fixing debug build.

This commit is contained in:
Nikolai Kochetov 2024-10-01 12:39:18 +00:00
parent d06de16d52
commit 09dcd6322d
5 changed files with 5 additions and 5 deletions

View File

@ -154,7 +154,7 @@ namespace DB
if (pipe.empty())
{
assert(output_stream != std::nullopt);
assert(output_header != std::nullopt);
pipe = Pipe(std::make_shared<NullSource>(*output_header));
}

View File

@ -130,7 +130,7 @@ void ReadFromMemoryStorageStep::initializePipeline(QueryPipelineBuilder & pipeli
if (pipe.empty())
{
assert(output_stream != std::nullopt);
assert(output_header != std::nullopt);
pipe = Pipe(std::make_shared<NullSource>(*output_header));
}

View File

@ -478,7 +478,7 @@ void ReadFromParallelRemoteReplicasStep::addPipeForSingeReplica(
String query_string = formattedAST(query_ast);
assert(stage != QueryProcessingStage::Complete);
assert(output_stream);
assert(output_header);
auto remote_query_executor = std::make_shared<RemoteQueryExecutor>(
pool,

View File

@ -433,7 +433,7 @@ void ReadFromSystemNumbersStep::initializePipeline(QueryPipelineBuilder & pipeli
if (pipe.empty())
{
assert(output_stream != std::nullopt);
assert(output_header != std::nullopt);
pipe = Pipe(std::make_shared<NullSource>(*output_header));
}

View File

@ -53,7 +53,7 @@ QueryPipelineBuilderPtr UnionStep::updatePipeline(QueryPipelineBuilders pipeline
for (auto & cur_pipeline : pipelines)
{
#if !defined(NDEBUG)
assertCompatibleHeader(cur_pipeline->getHeader(), getOutputHeader().header, "UnionStep");
assertCompatibleHeader(cur_pipeline->getHeader(), getOutputHeader(), "UnionStep");
#endif
/// Headers for union must be equal.
/// But, just in case, convert it to the same header if not.