diff options
author | d-mokhnatkin <d-mokhnatkin@yandex-team.ru> | 2022-02-17 13:20:43 +0300 |
---|---|---|
committer | d-mokhnatkin <d-mokhnatkin@yandex-team.ru> | 2022-02-17 13:20:43 +0300 |
commit | aadaa2fe92be460af8715c47f97faec8b5b9c8a6 (patch) | |
tree | cfcece22cc0f16d5ff7f30e58b5de1afff05b5e0 | |
parent | b19ffd720e0480be0e9474c947b5c9d9d5cbf3fa (diff) | |
download | ydb-aadaa2fe92be460af8715c47f97faec8b5b9c8a6.tar.gz |
YQ-848: fix hopping with only HOP_START parsing
ref:143c09e75b88c3c7dde836f5099c6e67d1d2a9cf
-rw-r--r-- | ydb/library/yql/sql/v1/node.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/library/yql/sql/v1/node.cpp b/ydb/library/yql/sql/v1/node.cpp index bd9a303e09..364c1ec946 100644 --- a/ydb/library/yql/sql/v1/node.cpp +++ b/ydb/library/yql/sql/v1/node.cpp @@ -1737,7 +1737,7 @@ bool ISource::SetSamplingRate(TContext& ctx, TNodePtr samplingRate) { } TNodePtr ISource::BuildAggregation(const TString& label) { - if (GroupKeys.empty() && Aggregations.empty() && !IsCompositeSource()) { + if (GroupKeys.empty() && Aggregations.empty() && !IsCompositeSource() && !HoppingWindowSpec) { return nullptr; } |