diff options
| author | ilnaz <ilnaz@yandex-team.com> | 2024-12-13 13:23:45 +0300 |
|---|---|---|
| committer | ilnaz <ilnaz@yandex-team.com> | 2024-12-13 14:40:50 +0300 |
| commit | 4526714adffb9a72bcf8e217ace99c462ef8fe1f (patch) | |
| tree | 4d7b5d8ec9b1bb6e30b3c65e692444f514782089 /yql/essentials/sql/v1/query.cpp | |
| parent | 7e12365effe19ba025ad585c13c2a6b68bfe4703 (diff) | |
| download | ydb-4526714adffb9a72bcf8e217ace99c462ef8fe1f.tar.gz | |
RESOLVED_TIMESTAMPS => BARRIERS_INTERVAL (part 2)
Part 1: [https://github.com/ydb-platform/ydb/pull/12555](https://github.com/ydb-platform/ydb/pull/12555/files)
commit_hash:6fec02d61652f1b4ee5fd2c677f4cedb547ef9ac
Diffstat (limited to 'yql/essentials/sql/v1/query.cpp')
| -rw-r--r-- | yql/essentials/sql/v1/query.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/yql/essentials/sql/v1/query.cpp b/yql/essentials/sql/v1/query.cpp index 8e71da3146..2f58ec5dfb 100644 --- a/yql/essentials/sql/v1/query.cpp +++ b/yql/essentials/sql/v1/query.cpp @@ -370,8 +370,8 @@ static INode::TPtr CreateChangefeedDesc(const TChangefeedDescription& desc, cons if (desc.Settings.VirtualTimestamps) { settings = node.L(settings, node.Q(node.Y(node.Q("virtual_timestamps"), desc.Settings.VirtualTimestamps))); } - if (desc.Settings.ResolvedTimestamps) { - settings = node.L(settings, node.Q(node.Y(node.Q("resolved_timestamps"), desc.Settings.ResolvedTimestamps))); + if (desc.Settings.BarriersInterval) { + settings = node.L(settings, node.Q(node.Y(node.Q("barriers_interval"), desc.Settings.BarriersInterval))); } if (desc.Settings.RetentionPeriod) { settings = node.L(settings, node.Q(node.Y(node.Q("retention_period"), desc.Settings.RetentionPeriod))); |