diff options
| author | aneporada <aneporada@yandex-team.ru> | 2022-04-26 20:03:22 +0300 |
|---|---|---|
| committer | aneporada <aneporada@yandex-team.ru> | 2022-04-26 20:03:22 +0300 |
| commit | dee977feb93b40d6d029a387e56d7ddfde7dae0a (patch) | |
| tree | 7e5e11818d28bf9d746cf1330c2bf23fc60eab37 | |
| parent | f8fe05cc5b57a33a4ccb47cb8bcf7c3b393961ed (diff) | |
| download | ydb-dee977feb93b40d6d029a387e56d7ddfde7dae0a.tar.gz | |
[YQL-14742] Mark all columns as used in extended SessionWindow
ref:9c86b07d15a9d25a5c33c1bbee5a22b32a3540a9
| -rw-r--r-- | ydb/library/yql/sql/v1/builtin.cpp | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/ydb/library/yql/sql/v1/builtin.cpp b/ydb/library/yql/sql/v1/builtin.cpp index 07f6d718f1..791bf9c791 100644 --- a/ydb/library/yql/sql/v1/builtin.cpp +++ b/ydb/library/yql/sql/v1/builtin.cpp @@ -1897,6 +1897,7 @@ bool TSessionWindow::DoInit(TContext& ctx, ISource* src) { auto initLambda = Args[1]; auto updateLambda = Args[2]; auto calculateLambda = Args[3]; + src->AllColumns(); return orderExpr->Init(ctx, src) && initLambda->Init(ctx, FakeSource.Get()) && updateLambda->Init(ctx, FakeSource.Get()) && calculateLambda->Init(ctx, FakeSource.Get()); |