Skip to content

Commit d0f24bd

Browse files
authored
Merge 013b173 into f759853
2 parents f759853 + 013b173 commit d0f24bd

File tree

2 files changed

+8
-6
lines changed

2 files changed

+8
-6
lines changed

.github/config/muted_ya.txt

+4
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

+4-6
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)