diff options
| author | Nikita Vasilev <ns-vasilev@ydb.tech> | 2024-09-03 13:45:26 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-09-03 13:45:26 +0300 |
| commit | 199ba9deaf317b084e6841d87b2dfbbaef221ad4 (patch) | |
| tree | 267f5353673ecc1295ca5b0962ce5c5961d9e941 | |
| parent | 40ed3711cff13f135fefa1a0c9dc43fe25426ec3 (diff) | |
| download | ydb-199ba9deaf317b084e6841d87b2dfbbaef221ad4.tar.gz | |
Enable CTAS Immediate EvWrite for CS (#8578)
| -rw-r--r-- | .github/config/muted_ya.txt | 4 | ||||
| -rw-r--r-- | ydb/core/kqp/host/kqp_statement_rewrite.cpp | 10 |
2 files changed, 8 insertions, 6 deletions
diff --git a/.github/config/muted_ya.txt b/.github/config/muted_ya.txt index b7b79ba74b..ed965aa738 100644 --- a/.github/config/muted_ya.txt +++ b/.github/config/muted_ya.txt @@ -15,6 +15,10 @@ ydb/core/kqp/ut/olap KqpOlapStatistics.StatsUsageWithTTL ydb/core/kqp/ut/pg KqpPg.CreateIndex ydb/core/kqp/ut/query KqpLimits.QueryReplySize ydb/core/kqp/ut/query KqpQuery.QueryTimeout +ydb/core/kqp/ut/query KqpQuery.OlapCreateAsSelect_Complex +ydb/core/kqp/ut/query KqpQuery.OlapCreateAsSelect_Simple +ydb/core/kqp/ut/federated_query/s3 KqpFederatedQuery.CreateTableAsSelectFromExternalDataSource +ydb/core/kqp/ut/federated_query/s3 KqpFederatedQuery.CreateTableAsSelectFromExternalTable ydb/core/kqp/ut/scan KqpRequestContext.TraceIdInErrorMessage ydb/core/kqp/ut/scheme [*/*]* ydb/core/kqp/ut/scheme KqpOlapScheme.DropThenAddColumn diff --git a/ydb/core/kqp/host/kqp_statement_rewrite.cpp b/ydb/core/kqp/host/kqp_statement_rewrite.cpp index cbc2194cd1..fa06bf64bf 100644 --- a/ydb/core/kqp/host/kqp_statement_rewrite.cpp +++ b/ydb/core/kqp/host/kqp_statement_rewrite.cpp @@ -213,12 +213,10 @@ namespace { exprCtx.NewAtom(pos, "mode"), exprCtx.NewAtom(pos, "replace"), })); - if (!isOlap) { - insertSettings.push_back( - exprCtx.NewList(pos, { - exprCtx.NewAtom(pos, "AllowInconsistentWrites"), - })); - } + insertSettings.push_back( + exprCtx.NewList(pos, { + exprCtx.NewAtom(pos, "AllowInconsistentWrites"), + })); const auto insert = exprCtx.NewCallable(pos, "Write!", { topLevelRead == nullptr ? exprCtx.NewWorld(pos) : exprCtx.NewCallable(pos, "Left!", {topLevelRead.Get()}), |