fetch additional fields in special corner case (#2116)

Author: ivanmorozov333

ydb/core/tx/columnshard/engines/reader/plain_reader/columns_set.h

@@ -106,6 +106,15 @@ class TColumnsSet {
         return true;
     }
 
+    bool Cross(const TColumnsSet& columnsSet) const {
+        for (auto&& i : columnsSet.ColumnIds) {
+            if (ColumnIds.contains(i)) {
+                return true;
+            }
+        }
+        return false;
+    }
+
     bool IsEqual(const TColumnsSet& columnsSet) const {
         if (columnsSet.GetColumnIds().size() != ColumnIds.size()) {
             return false;

ydb/core/tx/columnshard/engines/reader/plain_reader/context.cpp

@@ -51,7 +51,7 @@ std::shared_ptr<NKikimr::NOlap::NPlainReader::IFetchingStep> TSpecialReadContext
         }
     } else if (exclusiveSource) {
         TColumnsSet columnsFetch = *EFColumns;
-        if (needSnapshots || FFColumns->Contains(SpecColumns)) {
+        if (needSnapshots || FFColumns->Cross(*SpecColumns)) {
             columnsFetch = columnsFetch + *SpecColumns;
         }
         if (partialUsageByPredicate) {
@@ -60,7 +60,7 @@ std::shared_ptr<NKikimr::NOlap::NPlainReader::IFetchingStep> TSpecialReadContext
         AFL_VERIFY(columnsFetch.GetColumnsCount());
         current = current->AttachNext(std::make_shared<TBlobsFetchingStep>(std::make_shared<TColumnsSet>(columnsFetch), "ef"));
 
-        if (needSnapshots || FFColumns->Contains(SpecColumns)) {
+        if (needSnapshots || FFColumns->Cross(*SpecColumns)) {
             current = current->AttachNext(std::make_shared<TAssemblerStep>(SpecColumns));
             current = current->AttachNext(std::make_shared<TSnapshotFilter>());
             columnsFetch = columnsFetch - *SpecColumns;

ydb/core/tx/columnshard/engines/reader/plain_reader/context.h

@@ -23,9 +23,6 @@ class TSpecialReadContext {
     NIndexes::TIndexCheckerContainer IndexChecker;
     TReadMetadata::TConstPtr ReadMetadata;
     std::shared_ptr<TColumnsSet> EmptyColumns = std::make_shared<TColumnsSet>();
-    std::shared_ptr<TColumnsSet> PKFFColumns;
-    std::shared_ptr<TColumnsSet> EFPKColumns;
-    std::shared_ptr<TColumnsSet> FFMinusEFColumns;
     std::shared_ptr<IFetchingStep> BuildColumnsFetchingPlan(const bool needSnapshotsFilter, const bool exclusiveSource, const bool partialUsageByPredicate) const;
     std::array<std::array<std::array<std::shared_ptr<IFetchingStep>, 2>, 2>, 2> CacheFetchingScripts;
 public: