diff options
| author | Nikita Vasilev <ns-vasilev@ydb.tech> | 2024-07-08 14:34:41 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-07-08 14:34:41 +0300 |
| commit | f94fdc342be22a31c40a6e49f600f87abd166f90 (patch) | |
| tree | 89dde9bda36db4a68b375a649d88addc784c2325 | |
| parent | d20552c258db9a1b1212f16be58b617ce6945b2a (diff) | |
| download | ydb-f94fdc342be22a31c40a6e49f600f87abd166f90.tar.gz | |
Enable update for oltp sink (#6393)CLI_2.11.0
| -rw-r--r-- | ydb/core/kqp/opt/physical/effects/kqp_opt_phy_update.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/core/kqp/opt/physical/effects/kqp_opt_phy_update.cpp b/ydb/core/kqp/opt/physical/effects/kqp_opt_phy_update.cpp index 39550e7704..ad89fb36ff 100644 --- a/ydb/core/kqp/opt/physical/effects/kqp_opt_phy_update.cpp +++ b/ydb/core/kqp/opt/physical/effects/kqp_opt_phy_update.cpp @@ -91,7 +91,7 @@ TExprBase KqpBuildUpdateStages(TExprBase node, TExprContext& ctx, const TKqpOpti const auto& table = kqpCtx.Tables->ExistingTable(kqpCtx.Cluster, update.Table().Path()); - const bool isSink = NeedSinks(table, kqpCtx) && table.Metadata->Kind == EKikimrTableKind::Olap; + const bool isSink = NeedSinks(table, kqpCtx); const bool needPrecompute = !isSink; if (needPrecompute) { |