Skip to content

Commit f94fdc3

Browse files
authored
Enable update for oltp sink (#6393)
1 parent d20552c commit f94fdc3

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

ydb/core/kqp/opt/physical/effects/kqp_opt_phy_update.cpp

+1-1
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,7 @@ TExprBase KqpBuildUpdateStages(TExprBase node, TExprContext& ctx, const TKqpOpti
9191

9292
const auto& table = kqpCtx.Tables->ExistingTable(kqpCtx.Cluster, update.Table().Path());
9393

94-
const bool isSink = NeedSinks(table, kqpCtx) && table.Metadata->Kind == EKikimrTableKind::Olap;
94+
const bool isSink = NeedSinks(table, kqpCtx);
9595
const bool needPrecompute = !isSink;
9696

9797
if (needPrecompute) {

0 commit comments

Comments
 (0)