|
@@ -4134,7 +4134,11 @@ public:
|
|
ActPrintLog("HASHAGGREGATE: stopping");
|
|
ActPrintLog("HASHAGGREGATE: stopping");
|
|
if (localAggTable)
|
|
if (localAggTable)
|
|
localAggTable->reset();
|
|
localAggTable->reset();
|
|
- aggregateStream.clear();
|
|
|
|
|
|
+ if (aggregateStream)
|
|
|
|
+ {
|
|
|
|
+ aggregateStream->stop();
|
|
|
|
+ aggregateStream.clear();
|
|
|
|
+ }
|
|
PARENT::stop();
|
|
PARENT::stop();
|
|
}
|
|
}
|
|
virtual void abort() override
|
|
virtual void abort() override
|