first test works

Author: lll-phill-lll

ydb/library/yql/minikql/comp_nodes/mkql_wide_combine.cpp

@@ -554,10 +554,10 @@ class TSpillingSupportState : public TComputationValue<TSpillingSupportState> {
         std::cerr << std::format("MISHA: {} {} {}\n", AllowSpilling, (bool)Ctx.SpillerFactory, IsSwitchToSpillingModeCondition());
         if (AllowSpilling && Ctx.SpillerFactory && IsSwitchToSpillingModeCondition()) {
             std::cerr << "MISHA spilling enabled" << std::endl;
-            const auto used = TlsAllocState->GetUsed();
-            const auto limit = TlsAllocState->GetLimit();
+            // const auto used = TlsAllocState->GetUsed();
+            // const auto limit = TlsAllocState->GetLimit();
 
-            YQL_LOG(INFO) << "yellow zone reached " << (used*100/limit) << "%=" << used << "/" << limit;
+            // YQL_LOG(INFO) << "yellow zone reached " << (used*100/limit) << "%=" << used << "/" << limit;
             YQL_LOG(INFO) << "switching Memory mode to Spilling";
 
             SwitchMode(EOperatingMode::Spilling);

ydb/library/yql/minikql/comp_nodes/ut/mkql_wide_combine_ut.cpp

@@ -1066,16 +1066,26 @@ Y_UNIT_TEST_SUITE(TMiniKQLWideLastCombinerTest) {
         ));
 
         const auto graph = setup.BuildGraph(pgmReturn);
+        graph->GetContext().SpillerFactory = std::make_shared<TMockSpillerFactory>();
         const auto iterator = graph->GetValue().GetListIterator();
+
+        std::unordered_set<TString> expected {
+            "key one",
+            "very long value 2 / key two",
+            "very long key one",
+            "very long value 8 / very long value 7 / very long value 6"
+        };
+
         NUdf::TUnboxedValue item;
-        UNIT_ASSERT(iterator.Next(item));
-        UNBOXED_VALUE_STR_EQUAL(item, "key one");
-        UNIT_ASSERT(iterator.Next(item));
-        UNBOXED_VALUE_STR_EQUAL(item, "very long value 2 / key two");
-        UNIT_ASSERT(iterator.Next(item));
-        UNBOXED_VALUE_STR_EQUAL(item, "very long key one");
-        UNIT_ASSERT(iterator.Next(item));
-        UNBOXED_VALUE_STR_EQUAL(item, "very long value 8 / very long value 7 / very long value 6");
+        while (!expected.empty()) {
+            UNIT_ASSERT(iterator.Next(item));
+            // const auto actual = item.AsStringRef();
+            TString actual = item.AsStringRef().Data();
+
+            auto it = expected.find(actual);
+            UNIT_ASSERT(it != expected.end());
+            expected.erase(it);
+        }
         UNIT_ASSERT(!iterator.Next(item));
         UNIT_ASSERT(!iterator.Next(item));
     }