streamlookup: fix zero default for MaxDelayedRows (ydb-platform#10735)

qyryq · Oct 23, 2024 · cf5cb23 · cf5cb23
1 parent 9f0b790
commit cf5cb23
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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