Reverting change that breaks live view tests.

This commit is contained in:
Vitaliy Zakaznikov 2021-11-02 20:20:48 -04:00
parent 239432009b
commit db4a914b07

View File

@ -18,6 +18,7 @@ limitations under the License. */
#include <Processors/Sources/BlocksSource.h>
#include <Processors/Sinks/EmptySink.h>
#include <Processors/Transforms/MaterializingTransform.h>
#include <Processors/Executors/PullingPipelineExecutor.h>
#include <Processors/Executors/PullingAsyncPipelineExecutor.h>
#include <Processors/Transforms/SquashingChunksTransform.h>
#include <Processors/Transforms/ExpressionTransform.h>
@ -385,7 +386,7 @@ bool StorageLiveView::getNewBlocks()
auto builder = completeQuery(std::move(from));
auto pipeline = QueryPipelineBuilder::getPipeline(std::move(builder));
PullingAsyncPipelineExecutor executor(pipeline);
PullingPipelineExecutor executor(pipeline);
Block block;
while (executor.pull(block))
{