@@ -186,7 +186,7 @@ std::shared_ptr<TFetchingScript> TSpecialReadContext::BuildColumnsFetchingPlan(c
186186 acc.AddAssembleStep (*result, *DeletionColumns, " SPEC_DELETION" , EStageFeaturesIndexes::Fetching, false );
187187 result->AddStep (std::make_shared<TDeletionFilter>());
188188 }
189- acc.AddAssembleStep (*result, columnsFetch, " LAST" , EStageFeaturesIndexes::Fetching, true );
189+ acc.AddAssembleStep (*result, columnsFetch, " LAST" , EStageFeaturesIndexes::Fetching, !exclusiveSource );
190190 } else {
191191 return nullptr ;
192192 }
@@ -233,7 +233,7 @@ std::shared_ptr<TFetchingScript> TSpecialReadContext::BuildColumnsFetchingPlan(c
233233 result->AddStep (std::make_shared<TFilterCutLimit>(GetReadMetadata ()->Limit , GetReadMetadata ()->IsDescSorted ()));
234234 }
235235 acc.AddFetchingStep (*result, *FFColumns, EStageFeaturesIndexes::Fetching);
236- acc.AddAssembleStep (*result, *FFColumns, " LAST" , EStageFeaturesIndexes::Fetching, true );
236+ acc.AddAssembleStep (*result, *FFColumns, " LAST" , EStageFeaturesIndexes::Fetching, !exclusiveSource );
237237 } else {
238238 result->SetBranchName (" merge" );
239239 TColumnsSet columnsFetch = *MergeColumns + *EFColumns;
@@ -267,7 +267,7 @@ std::shared_ptr<TFetchingScript> TSpecialReadContext::BuildColumnsFetchingPlan(c
267267 }
268268 }
269269 acc.AddFetchingStep (*result, *FFColumns, EStageFeaturesIndexes::Fetching);
270- acc.AddAssembleStep (*result, *FFColumns, " LAST" , EStageFeaturesIndexes::Fetching, true );
270+ acc.AddAssembleStep (*result, *FFColumns, " LAST" , EStageFeaturesIndexes::Fetching, !exclusiveSource );
271271 }
272272 return result;
273273}
0 commit comments