Always recalculate column groups for operations with copy/merge dependencies

commit_hash:0eb58722ea067f220978fd3e9f01914096fce072

1 files changed, 6 insertions, 1 deletions

diff --git a/yt/yql/providers/yt/provider/yql_yt_physical_finalizing.cpp b/yt/yql/providers/yt/provider/yql_yt_physical_finalizing.cpp
index ac7a3cb79b..b44fd4918a 100644
--- a/yt/yql/providers/yt/provider/yql_yt_physical_finalizing.cpp
+++ b/yt/yql/providers/yt/provider/yql_yt_physical_finalizing.cpp
@@ -2862,7 +2862,12 @@ private:
 
             // Check all counsumers are known
             auto& processed = ProcessedCalculateColumnGroups[writer];
-            if (processed.size() == readers.size() && AllOf(readers, [&processed](const auto& item) { return processed.contains(std::get<0>(item)->UniqueId()); })) {
+            if (processed.size() == readers.size() &&
+                AllOf(readers, [&processed](const auto& item) {
+                    // Always reprocess ops with merge/copy readers
+                    return !TYtCopy::Match(std::get<0>(item)) && !TYtMerge::Match(std::get<0>(item)) && processed.contains(std::get<0>(item)->UniqueId());
+                })
+            ) {
                 continue;
             }
             processed.clear();