fixes

Author: ivanmorozov333

ydb/core/formats/arrow/program/filter.cpp

@@ -60,9 +60,8 @@ class TFilterVisitor: public arrow::ArrayVisitor {
     arrow::Status VisitImpl(const TArray& array) {
         AFL_VERIFY(Started);
         for (ui32 i = 0; i < array.length(); ++i) {
-            const bool columnValue = !array.IsNull(i) && (bool)array.Value(i);
             const ui32 currentIdx = CursorIdx++;
-            FiltersMerged[currentIdx] = FiltersMerged[currentIdx] && columnValue;
+            FiltersMerged[currentIdx] = FiltersMerged[currentIdx] && !array.IsNull(i) && (bool)array.Value(i);
         }
         AFL_VERIFY(CursorIdx <= FiltersMerged.size());
         return arrow::Status::OK();

ydb/core/formats/arrow/program/graph.cpp

@@ -212,13 +212,19 @@ TConclusion<std::vector<std::shared_ptr<IResourceProcessor>>> TGraph::BuildChain
     if (readyNodeIds.size() != Nodes.size()) {
         std::set<ui32> notCoveredIds;
         TStringBuilder sb;
+        ui32 count = 0;
         for (auto&& [id, n] : Nodes) {
             if (!readyNodeIds.contains(id)) {
+                if (n->GetProcessor()->GetProcessorType() != EProcessorType::Const) {
+                    ++count;
+                }
                 sb << n->DebugJson().GetStringRobust() << "/" << n->GetProcessor()->DebugJson().GetStringRobust() << Endl;
             }
         }
-        return TConclusionStatus::Fail(
-            "not found final nodes: " + ::ToString(readyNodeIds.size()) + " covered from " + ::ToString(Nodes.size()) + ": details = " + sb);
+        if (count) {
+            return TConclusionStatus::Fail(
+                "not found final nodes: " + ::ToString(readyNodeIds.size()) + " covered from " + ::ToString(Nodes.size()) + ": details = " + sb);
+        }
     }
     std::vector<std::shared_ptr<IResourceProcessor>> result;
     for (auto&& c : nodeChains) {