Fix cluster for StatWriteTable

nepal · nepal · commit 7aaaeef499bd · 2025-04-21T22:48:38.000+03:00
commit_hash:5b013b23327d8b623fbe133c80d2188f62b421a6
diff --git a/yt/yql/providers/yt/provider/phy_opt/yql_yt_phy_opt_write.cpp b/yt/yql/providers/yt/provider/phy_opt/yql_yt_phy_opt_write.cpp
@@ -693,6 +693,7 @@ TMaybeNode<TExprBase> TYtPhysicalOptProposalTransformer::ReplaceStatWriteTable(T
         newInput = path.Table().Cast<TYtOutput>();
     } else if (auto op = input.Maybe<TYtOutput>().Operation()) {
         newInput = input.Cast<TYtOutput>();
+        cluster = GetClusterName(input);
     } else {
         YQL_ENSURE(false, "Unexpected operation input: " << input.Ptr()->Content());
     }

Original file line number	Diff line number	Diff line change
`@@ -693,6 +693,7 @@ TMaybeNode<TExprBase> TYtPhysicalOptProposalTransformer::ReplaceStatWriteTable(T`
`693`	`693`	`newInput = path.Table().Cast<TYtOutput>();`
`694`	`694`	`} else if (auto op = input.Maybe<TYtOutput>().Operation()) {`
`695`	`695`	`newInput = input.Cast<TYtOutput>();`
	`696`	`+ cluster = GetClusterName(input);`
`696`	`697`	`} else {`
`697`	`698`	`YQL_ENSURE(false, "Unexpected operation input: " << input.Ptr()->Content());`
`698`	`699`	`}`