Skip to content

Commit

Permalink
fix read_rows count with external group by
Browse files Browse the repository at this point in the history
  • Loading branch information
tavplubix committed Mar 18, 2024
1 parent ebaee8e commit 9af69b4
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 1 deletion.
2 changes: 1 addition & 1 deletion src/Processors/ISource.h
Expand Up @@ -44,7 +44,7 @@ class ISource : public IProcessor
void setStorageLimits(const std::shared_ptr<const StorageLimitsList> & storage_limits_) override;

/// Default implementation for all the sources.
std::optional<ReadProgress> getReadProgress() final;
std::optional<ReadProgress> getReadProgress() override;

void addTotalRowsApprox(size_t value);
void addTotalBytes(size_t value);
Expand Down
2 changes: 2 additions & 0 deletions src/Processors/Transforms/AggregatingTransform.cpp
Expand Up @@ -80,6 +80,8 @@ namespace
return convertToChunk(block);
}

std::optional<ReadProgress> getReadProgress() override { return std::nullopt; }

private:
TemporaryFileStream * tmp_stream;
};
Expand Down

0 comments on commit 9af69b4

Please sign in to comment.