From 62bee6a90d3876dc1860d78ea3c28242abfd7613 Mon Sep 17 00:00:00 2001 From: Yuriy Kaminskiy Date: Tue, 22 Oct 2024 20:01:09 +0300 Subject: [PATCH] streamlookup: fix zero default for MaxDelayedRows --- ydb/library/yql/providers/dq/planner/execution_planner.cpp | 1 + 1 file changed, 1 insertion(+) diff --git a/ydb/library/yql/providers/dq/planner/execution_planner.cpp b/ydb/library/yql/providers/dq/planner/execution_planner.cpp index 6c611db479e1..82b119d727eb 100644 --- a/ydb/library/yql/providers/dq/planner/execution_planner.cpp +++ b/ydb/library/yql/providers/dq/planner/execution_planner.cpp @@ -613,6 +613,7 @@ namespace NYql::NDqs { const auto narrowOutputRowType = GetSeqItemType(streamLookup.Ptr()->GetTypeAnn()); Y_ABORT_UNLESS(narrowOutputRowType->GetKind() == ETypeAnnotationKind::Struct); settings.SetNarrowOutputRowType(NYql::NCommon::GetSerializedTypeAnnotation(narrowOutputRowType)); + settings.SetMaxDelayedRows(1'000'000); //TODO configure me settings.SetCacheLimit(1'000'000); //TODO configure me settings.SetCacheTtlSeconds(60); //TODO configure me