From ee65f3eedc78a818315473ffaa21424262720701 Mon Sep 17 00:00:00 2001 From: Nikolai Kochetov Date: Mon, 4 May 2020 21:07:56 +0300 Subject: [PATCH] Init all input ports in GroupingAggregatedTransform. --- .../Transforms/MergingAggregatedMemoryEfficientTransform.cpp | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/Processors/Transforms/MergingAggregatedMemoryEfficientTransform.cpp b/src/Processors/Transforms/MergingAggregatedMemoryEfficientTransform.cpp index 44445792228..bed1905f132 100644 --- a/src/Processors/Transforms/MergingAggregatedMemoryEfficientTransform.cpp +++ b/src/Processors/Transforms/MergingAggregatedMemoryEfficientTransform.cpp @@ -44,7 +44,10 @@ void GroupingAggregatedTransform::readFromAllInputs() in->setNeeded(); if (!in->hasData()) + { read_from_all_inputs = false; + continue; + } auto chunk = in->pull(); read_from_input[i] = true;