Query fails with filter optional side flag enabled

[gridnevvvit]

`
VERIFY failed (2025-10-24T16:14:10.748071+0300): Value is not a stream
yql/essentials/public/udf/udf_value_inl.h:574
Fetch(): requirement IsBoxed() failed
0. /place/sandbox-data/tasks/8/4/3471517348/ydb/util/system/yassert.cpp:86: NPrivate::InternalPanicImpl(int, char const*, char const*, int, int, int, TBasicStringBuf<char, std::__y1::char_traits>, char const*, unsigned long) @ 0x14AC3165

1. /place/sandbox-data/tasks/8/4/3471517348/ydb/util/system/yassert.cpp:55: NPrivate::Panic(NPrivate::TStaticBuf const&, int, char const*, char const*, char const*, ...) @ 0x14AB9E1B
2. /-S/yql/essentials/public/udf/udf_value_inl.h:574: NYql::NUdf::TUnboxedValuePod::Fetch(NYql::NUdf::TUnboxedValue&) const @ 0x24601E5F
3. /-S/ydb/core/kqp/runtime/kqp_stream_lookup_actor.cpp:613: NKikimr::NKqp::(anonymous namespace)::TKqpStreamLookupActor::FetchInputRows() @ 0x24601E5F
4. /-S/ydb/core/kqp/runtime/kqp_stream_lookup_actor.cpp:311: NKikimr::NKqp::(anonymous namespace)::TKqpStreamLookupActor::GetAsyncInputData(NKikimr::NMiniKQL::TUnboxedValueBatch&, TMaybe<TInstant, NMaybe::TPolicyUndefinedExcept>&, bool&, long) @ 0x24601E5F
5. /-S/ydb/library/yql/dq/actors/compute/dq_compute_actor_async_input_helper.h:73: NYql::NDq::TComputeActorAsyncInputHelper::PollAsyncInput(NYql::NDq::TDqComputeActorMetrics&, NYql::NDq::TDqComputeActorWatermarks&, long) @ 0x247E45FE
6. /-S/ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h:1488: NYql::NDq::TDqComputeActorBase<NKikimr::NKqp::TKqpComputeActor, NYql::NDq::TComputeActorAsyncInputHelperSync>::PollAsyncInput() @ 0x25B37122
7. /-S/ydb/library/yql/dq/actors/compute/dq_sync_compute_actor_base.h:33: NYql::NDq::TDqSyncComputeActorBaseNKikimr::NKqp::TKqpComputeActor::DoExecuteImpl() @ 0x25B34305
8. /-S/ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h:355: NYql::NDq::TDqComputeActorBase<NKikimr::NKqp::TKqpComputeActor, NYql::NDq::TComputeActorAsyncInputHelperSync>::DoExecute() @ 0x25B2C626
9. /-S/ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h:1108: NYql::NDq::TDqComputeActorBase<NKikimr::NKqp::TKqpComputeActor, NYql::NDq::TComputeActorAsyncInputHelperSync>::HandleExecuteBase(TAutoPtr<NActors::TEventHandleNYql::NDq::TEvDqCompute::TEvChannelsInfo, TDelete>&) @ 0x25B3BAE6
10. /-S/ydb/core/kqp/runtime/scheduler/kqp_compute_actor.h:37: NKikimr::NKqp::NScheduler::TSchedulableComputeActorBaseNKikimr::NKqp::TKqpComputeActor::BaseStateFuncBody(TAutoPtr<NActors::IEventHandle, TDelete>&) @ 0x25B29832
11. /-S/ydb/core/kqp/compute_actor/kqp_pure_compute_actor.cpp:163: NKikimr::NKqp::TKqpComputeActor::StateFunc(TAutoPtr<NActors::IEventHandle, TDelete>&) @ 0x25B29832
12. /place/sandbox-data/tasks/8/4/3471517348/ydb/ydb/library/actors/core/actor.cpp:350: NActors::IActor::Receive(TAutoPtr<NActors::IEventHandle, TDelete>&) @ 0x15C73CF7
13. /place/sandbox-data/tasks/8/4/3471517348/ydb/ydb/library/actors/core/executor_thread.cpp:267: NActors::TExecutorThread::Execute(NActors::TMailbox*, bool) @ 0x15CB70B4
14. /place/sandbox-data/tasks/8/4/3471517348/ydb/ydb/library/actors/core/executor_thread.cpp:455: NActors::TExecutorThread::ProcessExecutorPool()::$_0::operator()(NActors::TMailbox*, bool) const @ 0x15CBAFF1
15. /place/sandbox-data/tasks/8/4/3471517348/ydb/ydb/library/actors/core/executor_thread.cpp:507: NActors::TExecutorThread::ProcessExecutorPool() @ 0x15CBAC80
16. /place/sandbox-data/tasks/8/4/3471517348/ydb/ydb/library/actors/core/executor_thread.cpp:533: NActors::TExecutorThread::ThreadProc() @ 0x15CBB78E
17. /place/sandbox-data/tasks/8/4/3471517348/ydb/util/system/thread.cpp:245: (anonymous namespace)::TPosixThread::ThreadProxy(void*) @ 0x14AC47DC
18. ??:0: ?? @ 0x7FD45A14BAC2
19. ??:0: ?? @ 0x7FD45A1DD65F

`

[denis0x0D]

(declare %kqp%tx_result_binding_0_0 (TupleType (ListType (TupleType (TupleType (OptionalType (DataType 'Int32)) (DataType 'Int32)) (TupleType (OptionalType (DataType 'Int32)) (DataType 'Int32))))))
(let $1 (DataType 'Int32))
(let $2 (OptionalType $1))
(let $3 '('('"_logical_id" '18607) '('"_id" '"bbd21b9f-753f9f1a-2ba4738-61fcf047") '('"_partition_mode" '"single")))
(let $4 (DqPhyStage '() (lambda '() (block '(
  (let $79 (TupleType $1 $2 $1))
  (return (ToStream (Just '((RangeFinalize (RangeMultiply (Uint64 '10000) (RangeUnion (List (ListType (TupleType $79 $79))))))))))
))) $3))
(let $5 (DqCnValue (TDqOutput $4 '0)))
(let $6 (KqpPhysicalTx '($4) '($5) '() '('('"type" '"compute"))))
(let $7 (KqpTable '"/Root/Level1" '"72057594046644480:2" '"" '1))
(let $8 '"Level1_Optional_Id")
(let $9 '"Level1_Required_Id")
(let $10 '"OneToMany_Optional_Inverse2Id")
(let $11 '"OneToMany_Required_Inverse2Id")
(let $12 '"OneToOne_Optional_PK_Inverse2Id")
(let $13 '"OneToOne_Required_PK_Date")
(let $14 '('"Id" $1))
(let $15 (OptionalType (DataType 'Utf8)))
(let $16 (OptionalType (DataType 'Timestamp)))
(let $17 '"_equijoin_column_0")
(let $18 (DqPhyStage '() (lambda '() (block '(
  (let $80 '('"Id" $8 $9 '"Level2_Name" $10 $11 $12 $13))
  (let $81 (KqpBlockReadOlapTableRanges $7 (Void) $80 '() '() (lambda '($86) $86)))
  (let $82 (lambda '($87 $88 $89 $90 $91 $92 $93 $94 $95) (block '(
    (let $96 (BlockAsStruct '('"Id" $87) '($8 $88) '($9 $89) '('"Level2_Name" $90) '($10 $91) '($11 $92) '($12 $93) '($13 $94)))
    (return $96 $95)
  ))))
  (let $83 '('0))
  (let $84 (StructType $14 '($8 $2) '($9 $2) '('"Level2_Name" $15) '($10 $2) '($11 $2) '($12 $2) '($13 $16) '($17 $2)))
  (let $85 (lambda '($100) (AsStruct '('"Id" (Member $100 '"Id")))))
  (return (FromFlow (Switch (NarrowMap (ToFlow (WideFromBlocks (WideMap (FromFlow $81) $82))) (lambda '($97) $97)) '"134217728" $83 (lambda '($98) (EmptyIterator (FlowType $84))) $83 (lambda '($99) (Map $99 $85)) $83 (lambda '($101) (Filter (Map $101 $85) (lambda '($102) (block '(
    (let $103 (Member $102 '"Id"))
    (return (Or (== $103 (Int32 '1)) (== $103 (Int32 '"2"))))
  ))))) $83 (lambda '($104) (FlatMap $104 (lambda '($105) (block '(
    (let $106 (Member $105 $13))
    (let $107 (Exists $106))
    (let $108 (Member $105 $9))
    (let $109 (Exists $108))
    (let $110 (Member $105 $11))
    (let $111 (Exists $110))
    (let $112 (And $107 $109 $111))
    (let $113 (Member $105 '"Id"))
    (let $114 (If $112 (Just $113) (Nothing $2)))
    (let $115 (And $107 $109 $111 (Exists $114)))
    (return (If $115 (Just (AsStruct '('"Id" $113) '($8 (Member $105 $8)) '($9 $108) '('"Level2_Name" (Member $105 '"Level2_Name")) '($10 (Member $105 $10)) '($11 $110) '($12 (Member $105 $12)) '($13 $106) '($17 $114))) (Nothing (OptionalType $84))))
  ))))))))
))) '('('"_logical_id" '19665) '('"_id" '"abd05ca1-f6e491b9-376cf385-62fab7ba"))))
(let $19 (DqCnMap (TDqOutput $18 '"3")))
(let $20 (DqCnBroadcast (TDqOutput $18 '"2")))
(let $21 '('Many 'Hashed 'Compact))
(let $22 '($9))
(let $23 '('"Id"))
(let $24 '"l1.Level1_Optional_Id")
(let $25 '"l1.Level1_Required_Id")
(let $26 '"l1.OneToMany_Optional_Inverse2Id")
(let $27 '"l1.OneToMany_Required_Inverse2Id")
(let $28 '"l1.OneToOne_Optional_PK_Inverse2Id")
(let $29 '"l1.OneToOne_Required_PK_Date")
(let $30 '"l1._equijoin_column_0")
(let $31 '('"Id" '"l1.Id" $8 $24 $9 $25 '"Level2_Name" '"l1.Level2_Name" $10 $26 $11 $27 $12 $28 $13 $29 $17 $30))
(let $32 '($25))
(let $33 '('"l2.Id"))
(let $34 '('"l1.Id" $1))
(let $35 '($24 $2))
(let $36 '($25 $2))
(let $37 '('"l1.Level2_Name" $15))
(let $38 '($26 $2))
(let $39 '($27 $2))
(let $40 '($28 $2))
(let $41 '($29 $16))
(let $42 '($30 $2))
(let $43 (StructType $34 $35 $36 $37 $38 $39 $40 $41 $42 '('"l2.Id" $1)))
(let $44 '('('"_logical_id" '19410) '('"_id" '"60d6e889-6227876d-1247ecc4-a4e82bf5") '('"_wide_channels" $43)))
(let $45 (DqPhyStage '($19 $20) (lambda '($116 $117) (block '(
  (let $118 (SqueezeToDict (Map (ToFlow $117) (lambda '($120) '((Member $120 '"Id") $120))) (lambda '($121) (Nth $121 '0)) (lambda '($122) (Nth $122 '1)) $21))
  (let $119 (lambda '($125) (Member $125 '"l1.Id") (Member $125 $24) (Member $125 $25) (Member $125 '"l1.Level2_Name") (Member $125 $26) (Member $125 $27) (Member $125 $28) (Member $125 $29) (Member $125 $30) (Member $125 '"l2.Id")))
  (return (FromFlow (ExpandMap (FlatMap $118 (lambda '($123) (MapJoinCore (OrderedFilter (ToFlow $116) (lambda '($124) (Exists (Member $124 $9)))) $123 '"Inner" $22 $23 $31 '('"Id" '"l2.Id") $32 $33))) $119)))
))) $44))
(let $46 (DqCnMap (TDqOutput $18 '1)))
(let $47 (DqCnBroadcast (TDqOutput $45 '0)))
(let $48 '($30))
(let $49 '('"l1.Id" '"l1.Id" $24 $24 $25 $25 '"l1.Level2_Name" '"l1.Level2_Name" $26 $26 $27 $27 $28 $28 $29 $29))
(let $50 '('"l.Id"))
(let $51 (lambda '($154) (Just (Member $154 '"l1.Id")) (Member $154 $24) (Member $154 $25) (Member $154 '"l1.Level2_Name") (Member $154 $26) (Member $154 $27) (Member $154 $28) (Member $154 $29)))
(let $52 (StructType '('"l1.Id" $2) $35 $36 $37 $38 $39 $40 $41))
(let $53 '('"_wide_channels" $52))
(let $54 '('('"_logical_id" '19584) '('"_id" '"103c240c-e94cd4aa-98ebbb32-66f3e405") $53))
(let $55 (DqPhyStage '($46 $47) (lambda '($126 $127) (block '(
  (let $128 (SqueezeToDict (NarrowFlatMap (WideFilter (ToFlow $127) (lambda '($129 $130 $131 $132 $133 $134 $135 $136 $137 $138) (Exists $137))) (lambda '($139 $140 $141 $142 $143 $144 $145 $146 $147 $148) (IfPresent $147 (lambda '($149) (block '(
    (let $150 (AsStruct '('"l1.Id" $139) '($24 $140) '($25 $141) '('"l1.Level2_Name" $142) '($26 $143) '($27 $144) '($28 $145) '($29 $146) '($30 $147) '('"l2.Id" $148)))
    (return (Just '($149 $150)))
  ))) (Nothing (OptionalType (TupleType $1 $43)))))) (lambda '($151) (Nth $151 '0)) (lambda '($152) (Nth $152 '1)) $21))
  (return (FromFlow (ExpandMap (FlatMap $128 (lambda '($153) (MapJoinCore (ToFlow $126) $153 '"Inner" $23 $48 '() $49 $50 $48))) $51)))
))) $54))
(let $56 '"%kqp%tx_result_binding_0_0")
(let $57 (TupleType $2 $1))
(let $58 (TupleType (ListType (TupleType $57 $57))))
(let $59 (DqPhyStage '() (lambda '() (block '(
  (let $155 '('('"UsedKeyColumns" $23) '('"ExpectedMaxRanges" '1) '('"PointPrefixLen" '0)))
  (let $156 (KqpBlockReadOlapTableRanges $7 %kqp%tx_result_binding_0_0 $23 '() $155 (lambda '($159) $159)))
  (let $157 (lambda '($160 $161) (BlockAsStruct '('"Id" $160)) $161))
  (let $158 (lambda '($162) (block '(
    (let $163 (StructType $14))
    (let $164 (VariantType (TupleType $163 $163)))
    (let $165 (Variant $162 '0 $164))
    (let $166 (Variant $162 '1 $164))
    (return $165 $166)
  ))))
  (return (FromFlow (NarrowMultiMap (ToFlow (WideFromBlocks (WideMap (FromFlow $156) $157))) $158)))
))) '('('"_logical_id" '20244) '('"_id" '"b30d37f6-92b26e0f-5c00efa8-45d9caa9"))))
(let $60 (DqCnMap (TDqOutput $18 '0)))
(let $61 (DqCnBroadcast (TDqOutput $59 '1)))
(let $62 (StructType $34 $35 $36 $37 $38 $39 $40 $41 $42))
(let $63 '('('"_logical_id" '20299) '('"_id" '"d86ab03b-61d85fa7-98941a2d-5aee8414") '('"_wide_channels" $62)))
(let $64 (DqPhyStage '($60 $61) (lambda '($167 $168) (block '(
  (let $169 '('One 'Hashed 'Compact))
  (let $170 (SqueezeToDict (Map (ToFlow $168) (lambda '($172) (Member $172 '"Id"))) (lambda '($173) $173) (lambda '($174) (Void)) $169))
  (let $171 (lambda '($176) (Member $176 '"l1.Id") (Member $176 $24) (Member $176 $25) (Member $176 '"l1.Level2_Name") (Member $176 $26) (Member $176 $27) (Member $176 $28) (Member $176 $29) (Member $176 $30)))
  (return (FromFlow (ExpandMap (FlatMap $170 (lambda '($175) (MapJoinCore (ToFlow $167) $175 '"LeftOnly" $22 $23 $31 '() $32 $33))) $171)))
))) $63))
(let $65 (DqCnMap (TDqOutput $59 '0)))
(let $66 (DqCnBroadcast (TDqOutput $64 '0)))
(let $67 '('('"_logical_id" '20474) '('"_id" '"7a94112b-904ca852-d9694ca1-16265ea2") $53))
(let $68 (DqPhyStage '($65 $66) (lambda '($177 $178) (block '(
  (let $179 (SqueezeToDict (NarrowFlatMap (WideFilter (ToFlow $178) (lambda '($180 $181 $182 $183 $184 $185 $186 $187 $188) (Exists $188))) (lambda '($189 $190 $191 $192 $193 $194 $195 $196 $197) (IfPresent $197 (lambda '($198) (block '(
    (let $199 (AsStruct '('"l1.Id" $189) '($24 $190) '($25 $191) '('"l1.Level2_Name" $192) '($26 $193) '($27 $194) '($28 $195) '($29 $196) '($30 $197)))
    (return (Just '($198 $199)))
  ))) (Nothing (OptionalType (TupleType $1 $62)))))) (lambda '($200) (Nth $200 '0)) (lambda '($201) (Nth $201 '1)) $21))
  (return (FromFlow (ExpandMap (FlatMap $179 (lambda '($202) (MapJoinCore (ToFlow $177) $202 '"Inner" $23 $48 '() $49 $50 $48))) $51)))
))) $67))
(let $69 (DqCnParallelUnionAll (TDqOutput $55 '0)))
(let $70 (DqCnParallelUnionAll (TDqOutput $68 '0)))
(let $71 (DqPhyStage '($69 $70) (lambda '($203 $204) (block '(
  (let $205 (lambda '($206 $207 $208 $209 $210 $211 $212 $213) (AsStruct '('"l1.Id" $206) '($24 $207) '($25 $208) '('"l1.Level2_Name" $209) '($26 $210) '($27 $211) '($28 $212) '($29 $213))))
  (return (FromFlow (Extend (NarrowMap (ToFlow $203) $205) (NarrowMap (ToFlow $204) $205))))
))) '('('"_logical_id" '20526) '('"_id" '"b1884fef-cfa8c296-12453d17-b4392705"))))
(let $72 (DqCnUnionAll (TDqOutput $71 '0)))
(let $73 (DqPhyStage '($72) (lambda '($214) $214) '('('"_logical_id" '21570) '('"_id" '"3f25e870-74bd5ba4-381a9f63-b8ba82e5"))))
(let $74 '($18 $45 $55 $59 $64 $68 $71 $73))
(let $75 '('"l1.Id" $29 $24 $25 '"l1.Level2_Name" $26 $27 $28))
(let $76 (DqCnResult (TDqOutput $73 '0) $75))
(let $77 (KqpTxResultBinding $58 '0 '0))
(let $78 (KqpPhysicalTx $74 '($76) '('($56 $77)) '('('"type" '"generic"))))
(return (KqpPhysicalQuery '($6 $78) '((KqpTxResultBinding (ListType $52) '1 '0)) '('('"type" '"query"))))

[denis0x0D]

(let $1 (DataType 'Int32))
(let $2 (OptionalType $1))
(let $3 '('"_partition_mode" '"single"))
(let $4 '('('"_logical_id" '20363) '('"_id" '"f0fa6f06-929cfabb-cfacd3a7-bb4ef3dd") $3))
(let $5 (DqPhyStage '() (lambda '() (block '(
  (let $138 (TupleType $1 $2 $1))
  (return (ToStream (Just '((RangeFinalize (RangeMultiply (Uint64 '10000) (RangeUnion (List (ListType (TupleType $138 $138))))))))))
))) $4))
(let $6 (DqCnValue (TDqOutput $5 '0)))
(let $7 (KqpPhysicalTx '($5) '($6) '() '('('"type" '"compute"))))
(let $8 (DataSource '"KqpReadRangesSource"))
(let $9 (KqpTable '"/Root/Level1" '"72057594046644480:34" '"" '1))
(let $10 '('"Id"))
(let $11 (KqpRowsSourceSettings $9 $10 '() (Void) '()))
(let $12 (lambda '($139) (FromFlow (ExpandMap (ToFlow $139) (lambda '($140) (Member $140 '"Id"))))))
(let $13 '('"Id" $1))
(let $14 (StructType $13))
(let $15 '('"_wide_channels" $14))
(let $16 '('('"_logical_id" '20681) '('"_id" '"4fff56d4-51058444-2e0e67e-3761c4ba") $3 $15))
(let $17 (DqPhyStage '((DqSource $8 $11)) $12 $16))
(let $18 (KqpTable '"/Root/Level1/IX_Level1_Level1_Required_Id/indexImplTable" '"72057594046644480:38" '"" '1))
(let $19 '"IndexSelectionDebugInfo")
(let $20 '('"index:IX_Level1_OneToMany_Required_Inverse2Id" '"(0,0,0,0,1,0,0)"))
(let $21 '"index:IX_Level1_Level3_Required_Id")
(let $22 '"index:IX_Level1_OneToMany_Required_Inverse3Id")
(let $23 '"index:IX_Level1_Level2_Required_Id")
(let $24 '"index:IX_Level1_Level1_Optional_Id")
(let $25 '"index:IX_Level1_OneToMany_Optional_Inverse2Id")
(let $26 '"index:IX_Level1_OneToOne_Optional_PK_Inverse3Id")
(let $27 '"index:IX_Level1_OneToMany_Required_Inverse4Id")
(let $28 '"index:IX_Level1_OneToOne_Optional_PK_Inverse2Id")
(let $29 '"index:IX_Level1_OneToMany_Optional_Inverse3Id")
(let $30 '('"index:IX_Level1_Level1_Required_Id" '"(0,0,0,0,1,0,0)"))
(let $31 '"index:IX_Level1_Level3_Optional_Id")
(let $32 '"index:IX_Level1_OneToOne_Optional_PK_Inverse4Id")
(let $33 '"index:IX_Level1_Level2_Optional_Id")
(let $34 '"index:IX_Level1_OneToMany_Optional_Inverse4Id")
(let $35 '($20 '($21 '"(0,0,0,0,0,0,0)") '($22 '"(0,0,0,0,0,0,0)") '($23 '"(0,0,0,0,0,0,0)") '($24 '"(0,0,0,0,0,0,0)") '($25 '"(0,0,0,0,0,0,0)") '($26 '"(0,0,0,0,0,0,0)") '($27 '"(0,0,0,0,0,0,0)") '($28 '"(0,0,0,0,0,0,0)") '($29 '"(0,0,0,0,0,0,0)") $30 '($31 '"(0,0,0,0,0,0,0)") '($32 '"(0,0,0,0,0,0,0)") '($33 '"(0,0,0,0,0,0,0)") '($34 '"(0,0,0,0,0,0,0)")))
(let $36 (Nothing $2))
(let $37 (KqpRowsSourceSettings $18 $10 '('($19 $35)) '((KqlKeyExc $36) (KqlKeyInc))))
(let $38 '((DqSource $8 $37)))
(let $39 (lambda '($141) $141))
(let $40 '('"_logical_id" '22893))
(let $41 (DqPhyStage $38 $39 '($40 '('"_id" '"17873b05-25515134-a3ec6dc7-ba33d6e4"))))
(let $42 '"Level1_Optional_Id")
(let $43 '"Level1_Required_Id")
(let $44 '"OneToMany_Optional_Inverse2Id")
(let $45 '"OneToMany_Required_Inverse2Id")
(let $46 '"OneToOne_Optional_PK_Inverse2Id")
(let $47 '"OneToOne_Required_PK_Date")
(let $48 '('"Id" $42 $43 '"Level2_Name" $44 $45 $46 $47))
(let $49 (ListType $14))
(let $50 '('('"Strategy" '"LookupRows")))
(let $51 (KqpCnStreamLookup (TDqOutput $41 '0) $9 $48 $49 $50))
(let $52 '"_equijoin_column_0")
(let $53 (OptionalType (DataType 'Utf8)))
(let $54 (OptionalType (DataType 'Timestamp)))
(let $55 (StructType $13 '($42 $2) '($43 $2) '('"Level2_Name" $53) '($44 $2) '($45 $2) '($46 $2) '($47 $54) '($52 $2)))
(let $56 (lambda '($154) (Member $154 '"Id") (Member $154 $42) (Member $154 $43) (Member $154 '"Level2_Name") (Member $154 $44) (Member $154 $45) (Member $154 $46) (Member $154 $47) (Member $154 $52)))
(let $57 '('"_logical_id" '21482))
(let $58 '('"_wide_channels" $55))
(let $59 '($57 '('"_id" '"a20b2b18-9fb7e401-6bf0dd6f-5b0b3e26") $58))
(let $60 (DqPhyStage '($51) (lambda '($142) (FromFlow (ExpandMap (FlatMap (ToFlow $142) (lambda '($143) (block '(
  (let $144 (Member $143 $47))
  (let $145 (Exists $144))
  (let $146 (Member $143 $45))
  (let $147 (Exists $146))
  (let $148 (Member $143 $43))
  (let $149 (Exists $148))
  (let $150 (And $145 $149 $147))
  (let $151 (Member $143 '"Id"))
  (let $152 (If $150 (Just $151) $36))
  (let $153 (And $145 $147 (Exists $152) $149))
  (return (If $153 (Just (AsStruct '('"Id" $151) '($42 (Member $143 $42)) '($43 $148) '('"Level2_Name" (Member $143 '"Level2_Name")) '($44 (Member $143 $44)) '($45 $146) '($46 (Member $143 $46)) '($47 $144) '($52 $152))) (Nothing (OptionalType $55))))
)))) $56))) $59))
(let $61 (DqCnMap (TDqOutput $17 '0)))
(let $62 (DqCnBroadcast (TDqOutput $60 '0)))
(let $63 (lambda '($158 $159 $160 $161 $162 $163 $164 $165 $166) (Exists $166)))
(let $64 (lambda '($167 $168 $169 $170 $171 $172 $173 $174 $175) (IfPresent $175 (lambda '($176) (block '(
  (let $177 (AsStruct '('"Id" $167) '($42 $168) '($43 $169) '('"Level2_Name" $170) '($44 $171) '($45 $172) '($46 $173) '($47 $174) '($52 $175)))
  (return (Just '($176 $177)))
))) (Nothing (OptionalType (TupleType $1 $55))))))
(let $65 (lambda '($178) (Nth $178 '0)))
(let $66 (lambda '($179) (Nth $179 '1)))
(let $67 '('Many 'Hashed 'Compact))
(let $68 '('0))
(let $69 '($52))
(let $70 '('0 '0))
(let $71 '('"Id" '1 $42 '2 $43 '3 '"Level2_Name" '4 $44 '5 $45 '6 $46 '7 $47 '8 $52 '9))
(let $72 '('"l.Id"))
(let $73 '"l1._equijoin_column_0")
(let $74 '($73))
(let $75 '"l1.Level1_Optional_Id")
(let $76 '"l1.Level1_Required_Id")
(let $77 '"l1.OneToMany_Optional_Inverse2Id")
(let $78 '"l1.OneToMany_Required_Inverse2Id")
(let $79 '"l1.OneToOne_Optional_PK_Inverse2Id")
(let $80 '"l1.OneToOne_Required_PK_Date")
(let $81 (DqPhyStage '($61 $62) (lambda '($155 $156) (block '(
  (let $157 (SqueezeToDict (NarrowFlatMap (WideFilter (ToFlow $156) $63) $64) $65 $66 $67))
  (return (FromFlow (NarrowMap (FlatMap $157 (lambda '($180) (MapJoinCore (ToFlow $155) $180 '"Inner" $68 $69 $70 $71 $72 $74))) (lambda '($181 $182 $183 $184 $185 $186 $187 $188 $189 $190) (block '(
    (let $191 (AsStruct '('"l.Id" $181) '('"l1.Id" $182) '($75 $183) '($76 $184) '('"l1.Level2_Name" $185) '($77 $186) '($78 $187) '($79 $188) '($80 $189) '($73 $190)))
    (return '($191 (Just (AsStruct '('"Id" $184)))))
  ))))))
))) '('('"_logical_id" '21135) '('"_id" '"116c6dea-7c731ee7-c3b037dd-3c72cfea"))))
(let $82 '('"Date" '"Id" $42 $43 '"Level2_Name" '"Level2_Optional_Id" '"Level2_Required_Id" '"Level3_Name" '"Level3_Optional_Id" '"Level3_Required_Id" '"Level4_Name" '"Name" $44 '"OneToMany_Optional_Inverse3Id" '"OneToMany_Optional_Inverse4Id" $45 '"OneToMany_Required_Inverse3Id" '"OneToMany_Required_Inverse4Id" $46 '"OneToOne_Optional_PK_Inverse3Id" '"OneToOne_Optional_PK_Inverse4Id" $47))
(let $83 '($75 $2))
(let $84 '($76 $2))
(let $85 '('"l1.Level2_Name" $53))
(let $86 '($77 $2))
(let $87 '($78 $2))
(let $88 '($79 $2))
(let $89 '($80 $54))
(let $90 (StructType '('"l.Id" $1) '('"l1.Id" $1) $83 $84 $85 $86 $87 $88 $89 '($73 $2)))
(let $91 (KqpCnStreamLookup (TDqOutput $81 '0) $9 $82 (ListType (TupleType $90 (OptionalType (StructType '('"Id" $2))))) '('('"Strategy" '"LookupJoinRows") '('"AllowNullKeysPrefixSize" '0))))
(let $92 (lambda '($201) $201))
(let $93 (lambda '($202) (Void)))
(let $94 (DqPhyStage '($91) (lambda '($192) (Map $192 (lambda '($193) (block '(
  (let $194 (Nth $193 '1))
  (let $195 (Nothing (OptionalType $14)))
  (let $196 (IfPresent $194 (lambda '($197) (block '(
    (let $198 (List (ListType $1) (Int32 '1) (Int32 '2)))
    (let $199 (ToDict $198 $92 $93 '('One 'Auto)))
    (let $200 (IfPresent $194 (lambda '($203) (Just (AsStruct '('"Id" (Member $203 '"Id"))))) $195))
    (return (If (Contains $199 (Member $197 '"Id")) $200 $195))
  ))) $195))
  (return '((Nth $193 '0) $196 (Nth $193 '2)))
))))) '('('"_logical_id" '21255) '('"_id" '"d4edd3bd-473b8a04-6c57e644-4cea66bf"))))
(let $95 (DqCnUnionAll (TDqOutput $94 '0)))
(let $96 (StructType '('"l1.Id" $2) $83 $84 $85 $86 $87 $88 $89))
(let $97 '('"_wide_channels" $96))
(let $98 '('('"_logical_id" '21401) '('"_id" '"4ba16433-257ddd67-9e17397a-a6e11fa2") $97))
(let $99 (DqPhyStage '($95) (lambda '($204) (block '(
  (let $205 (lambda '($206) (Just (Member $206 '"l1.Id")) (Member $206 $75) (Member $206 $76) (Member $206 '"l1.Level2_Name") (Member $206 $77) (Member $206 $78) (Member $206 $79) (Member $206 $80)))
  (return (FromFlow (ExpandMap (ToFlow (KqpIndexLookupJoin $204 '"Inner" '"" '"l2")) $205)))
))) $98))
(let $100 '($20 '($21 '"(0,0,0,0,1,0,0)") '($22 '"(0,0,0,0,1,0,0)") '($23 '"(0,0,0,0,1,0,0)") '($24 '"(0,0,0,0,1,0,0)") '($25 '"(0,0,0,0,1,0,0)") '($26 '"(0,0,0,0,1,0,0)") '($27 '"(0,0,0,0,1,0,0)") '($28 '"(0,0,0,0,1,0,0)") '($29 '"(0,0,0,0,1,0,0)") $30 '($31 '"(0,0,0,0,1,0,0)") '($32 '"(0,0,0,0,1,0,0)") '($33 '"(0,0,0,0,1,0,0)") '($34 '"(0,0,0,0,1,0,0)")))
(let $101 '($19 $100))
(let $102 '"%kqp%tx_result_binding_0_0")
(let $103 (TupleType $2 $1))
(let $104 (TupleType (ListType (TupleType $103 $103))))
(let $105 '('('"UsedKeyColumns" $10) '('"ExpectedMaxRanges" '1) $101 '('"PointPrefixLen" '0)))
(let $106 (KqpRowsSourceSettings $9 $10 '($101) %kqp%tx_result_binding_0_0 $105))
(let $107 '((DqSource $8 $106)))
(let $108 '('"_logical_id" '21941))
(let $109 '($108 '('"_id" '"2e4b8137-4a7a396f-4a15e0b5-76eeaf05") $15))
(let $110 (DqPhyStage $107 $12 $109))
(let $111 (DqPhyStage $38 $39 '($40 '('"_id" '"14aa5a0c-581bbb25-9a189b26-bc5e6d5c"))))
(let $112 (KqpCnStreamLookup (TDqOutput $111 '0) $9 $48 $49 $50))
(let $113 '($57 '('"_id" '"638b657b-896ff2d7-6f302803-42cf000f") $58))
(let $114 (DqPhyStage '($112) (lambda '($207) (FromFlow (ExpandMap (EmptyIterator (FlowType $55)) $56))) $113))
(let $115 (DqCnMap (TDqOutput $110 '0)))
(let $116 (DqCnBroadcast (TDqOutput $114 '0)))
(let $117 '('('"_logical_id" '21999) '('"_id" '"c3012cf2-5f5a9107-2efa0061-fd4d945d") '('"_wide_channels" $90)))
(let $118 (DqPhyStage '($115 $116) (lambda '($208 $209) (block '(
  (let $210 (SqueezeToDict (NarrowFlatMap (WideFilter (ToFlow $209) $63) $64) $65 $66 $67))
  (return (FromFlow (FlatMap $210 (lambda '($211) (MapJoinCore (ToFlow $208) $211 '"Inner" $68 $69 $70 $71 $72 $74)))))
))) $117))
(let $119 '($108 '('"_id" '"a068c135-73193877-9bfdbe5b-a17e6594") $15))
(let $120 (DqPhyStage $107 $12 $119))
(let $121 (DqCnMap (TDqOutput $118 '0)))
(let $122 (DqCnBroadcast (TDqOutput $120 '0)))
(let $123 '('('"_logical_id" '22153) '('"_id" '"d5d28ef-ba18eb42-e97ee627-7414038c") $97))
(let $124 (DqPhyStage '($121 $122) (lambda '($212 $213) (block '(
  (let $214 '('One 'Hashed 'Compact))
  (let $215 (NarrowSqueezeToDict (ToFlow $213) $92 $93 $214))
  (let $216 (lambda '($230 $231 $232 $233 $234 $235 $236 $237) (Just $230) $231 $232 $233 $234 $235 $236 $237))
  (return (FromFlow (WideMap (FlatMap $215 (lambda '($217) (block '(
    (let $218 (lambda '($220 $221 $222 $223 $224 $225 $226 $227 $228 $229) $221 $222 $223 $224 $225 $226 $227 $228))
    (let $219 '('0 '0 '1 '1 '2 '2 '3 '3 '4 '4 '5 '5 '6 '6 '7 '7))
    (return (MapJoinCore (WideMap (ToFlow $212) $218) $217 '"LeftOnly" '('2) $10 $219 '() '($76) '('"l2.Id")))
  )))) $216)))
))) $123))
(let $125 (DqCnParallelUnionAll (TDqOutput $99 '0)))
(let $126 (DqCnParallelUnionAll (TDqOutput $124 '0)))
(let $127 (lambda '($241 $242 $243 $244 $245 $246 $247 $248) (AsStruct '('"l1.Id" $241) '($75 $242) '($76 $243) '('"l1.Level2_Name" $244) '($77 $245) '($78 $246) '($79 $247) '($80 $248))))
(let $128 (Uint64 '"1001"))
(let $129 '('('"_logical_id" '22263) '('"_id" '"99b62b87-1c869c6c-693963f5-504c5c81") $97))
(let $130 (DqPhyStage '($125 $126) (lambda '($238 $239) (block '(
  (let $240 (lambda '($249) (Member $249 '"l1.Id") (Member $249 $75) (Member $249 $76) (Member $249 '"l1.Level2_Name") (Member $249 $77) (Member $249 $78) (Member $249 $79) (Member $249 $80)))
  (return (FromFlow (ExpandMap (Take (Extend (NarrowMap (ToFlow $238) $127) (NarrowMap (ToFlow $239) $127)) $128) $240)))
))) $129))
(let $131 (DqCnUnionAll (TDqOutput $130 '0)))
(let $132 (DqPhyStage '($131) (lambda '($250) (FromFlow (NarrowMap (Take (ToFlow $250) $128) $127))) '('('"_logical_id" '22276) '('"_id" '"72b6dcb8-8c333318-aeffdd25-74989d1b"))))
(let $133 '($17 $41 $60 $81 $94 $99 $110 $111 $114 $118 $120 $124 $130 $132))
(let $134 '('"l1.Id" $80 $75 $76 '"l1.Level2_Name" $77 $78 $79))
(let $135 (DqCnResult (TDqOutput $132 '0) $134))
(let $136 (KqpTxResultBinding $104 '0 '0))
(let $137 (KqpPhysicalTx $133 '($135) '('($102 $136)) '('('"type" '"data"))))
(return (KqpPhysicalQuery '($7 $137) '((KqpTxResultBinding (ListType $96) '1 '0)) '('('"type" '"data_query"))))