From cf5cb2311b7c577e20446301ba4f2bd3a2054719 Mon Sep 17 00:00:00 2001 From: yumkam Date: Wed, 23 Oct 2024 15:01:03 +0300 Subject: [PATCH] streamlookup: fix zero default for MaxDelayedRows (#10735) --- 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