Merge 79ee673 into ce94a36

Author: dorooleg

ydb/core/tx/columnshard/engines/reader/abstract/constructor.cpp

@@ -8,27 +8,31 @@ namespace NKikimr::NOlap::NReader {
 
 NKikimr::TConclusionStatus IScannerConstructor::ParseProgram(const TVersionedIndex* vIndex, const NKikimrSchemeOp::EOlapProgramType programType,
     const TString& serializedProgram, TReadDescription& read, const NArrow::NSSA::IColumnResolver& columnResolver) const {
-    std::set<TString> namesChecker;
-    if (serializedProgram.empty()) {
-        if (!read.ColumnIds.size()) {
-            auto schema = vIndex->GetSchemaVerified(read.GetSnapshot());
-            read.ColumnIds = std::vector<ui32>(schema->GetColumnIds().begin(), schema->GetColumnIds().end());
-        }
-        TProgramContainer container;
-        AFL_DEBUG(NKikimrServices::TX_COLUMNSHARD_SCAN)("event", "overriden_columns")("ids", JoinSeq(",", read.ColumnIds));
-        container.OverrideProcessingColumns(read.ColumnIds);
-        read.SetProgram(std::move(container));
-        return TConclusionStatus::Success();
-    } else {
-        TProgramContainer ssaProgram;
-        auto statusInit = ssaProgram.Init(columnResolver, programType, serializedProgram);
-        if (statusInit.IsFail()) {
-            return TConclusionStatus::Fail(TStringBuilder() << "Can't parse SsaProgram: " << statusInit.GetErrorMessage());
-        }
+    try {
+        std::set<TString> namesChecker;
+        if (serializedProgram.empty()) {
+            if (!read.ColumnIds.size()) {
+                auto schema = vIndex->GetSchemaVerified(read.GetSnapshot());
+                read.ColumnIds = std::vector<ui32>(schema->GetColumnIds().begin(), schema->GetColumnIds().end());
+            }
+            TProgramContainer container;
+            AFL_DEBUG(NKikimrServices::TX_COLUMNSHARD_SCAN)("event", "overriden_columns")("ids", JoinSeq(",", read.ColumnIds));
+            container.OverrideProcessingColumns(read.ColumnIds);
+            read.SetProgram(std::move(container));
+            return TConclusionStatus::Success();
+        } else {
+            TProgramContainer ssaProgram;
+            auto statusInit = ssaProgram.Init(columnResolver, programType, serializedProgram);
+            if (statusInit.IsFail()) {
+                return TConclusionStatus::Fail(TStringBuilder() << "Can't parse SsaProgram: " << statusInit.GetErrorMessage());
+            }
 
-        read.SetProgram(std::move(ssaProgram));
+            read.SetProgram(std::move(ssaProgram));
 
-        return TConclusionStatus::Success();
+            return TConclusionStatus::Success();
+        }
+    } catch (...) {
+        return TConclusionStatus::Fail(TStringBuilder() << "Can't parse program, exception thrown: " << CurrentExceptionMessage());
     }
 }