We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 173a619 commit dab5942Copy full SHA for dab5942
src/Processors/QueryPlan/ReadFromObjectStorageStep.cpp
@@ -132,7 +132,7 @@ void ReadFromObjectStorageStep::initializePipeline(QueryPipelineBuilder & pipeli
132
size_t output_ports = pipe.numOutputPorts();
133
const bool parallelize_output = context->getSettingsRef()[Setting::parallelize_output_from_storages];
134
if (parallelize_output
135
- && FormatFactory::instance().checkParallelizeOutputAfterReading(configuration->format, context)
+ && FormatFactory::instance().checkParallelizeOutputAfterReading(configuration->getFormat(), context)
136
&& output_ports > 0 && output_ports < max_num_streams)
137
pipe.resize(max_num_streams);
138
0 commit comments