Skip to content

Commit 199ba9d

Browse files
authored
Enable CTAS Immediate EvWrite for CS (#8578)
1 parent 40ed371 commit 199ba9d

File tree

2 files changed

+8
-6
lines changed

2 files changed

+8
-6
lines changed

.github/config/muted_ya.txt

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,10 @@ ydb/core/kqp/ut/olap KqpOlapStatistics.StatsUsageWithTTL
1515
ydb/core/kqp/ut/pg KqpPg.CreateIndex
1616
ydb/core/kqp/ut/query KqpLimits.QueryReplySize
1717
ydb/core/kqp/ut/query KqpQuery.QueryTimeout
18+
ydb/core/kqp/ut/query KqpQuery.OlapCreateAsSelect_Complex
19+
ydb/core/kqp/ut/query KqpQuery.OlapCreateAsSelect_Simple
20+
ydb/core/kqp/ut/federated_query/s3 KqpFederatedQuery.CreateTableAsSelectFromExternalDataSource
21+
ydb/core/kqp/ut/federated_query/s3 KqpFederatedQuery.CreateTableAsSelectFromExternalTable
1822
ydb/core/kqp/ut/scan KqpRequestContext.TraceIdInErrorMessage
1923
ydb/core/kqp/ut/scheme [*/*]*
2024
ydb/core/kqp/ut/scheme KqpOlapScheme.DropThenAddColumn

ydb/core/kqp/host/kqp_statement_rewrite.cpp

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -213,12 +213,10 @@ namespace {
213213
exprCtx.NewAtom(pos, "mode"),
214214
exprCtx.NewAtom(pos, "replace"),
215215
}));
216-
if (!isOlap) {
217-
insertSettings.push_back(
218-
exprCtx.NewList(pos, {
219-
exprCtx.NewAtom(pos, "AllowInconsistentWrites"),
220-
}));
221-
}
216+
insertSettings.push_back(
217+
exprCtx.NewList(pos, {
218+
exprCtx.NewAtom(pos, "AllowInconsistentWrites"),
219+
}));
222220

223221
const auto insert = exprCtx.NewCallable(pos, "Write!", {
224222
topLevelRead == nullptr ? exprCtx.NewWorld(pos) : exprCtx.NewCallable(pos, "Left!", {topLevelRead.Get()}),

0 commit comments

Comments
 (0)