summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorva-kuznecov <[email protected]>2022-10-31 13:07:21 +0300
committerva-kuznecov <[email protected]>2022-10-31 13:07:21 +0300
commit18dbfee5bb16564165534f8008728df7cc8d595f (patch)
tree6eed062bd97153fe35a56e99a4644728fdf5d867
parent2f8f969f7018aa1115c7b64c56baacdc33e1011e (diff)
WIP. Solidify SessionActor in KQP UT
-rw-r--r--ydb/core/kqp/ut/common/kqp_ut_common.h10
-rw-r--r--ydb/core/kqp/ut/kqp_explain_ut.cpp88
-rw-r--r--ydb/core/kqp/ut/kqp_limits_ut.cpp18
-rw-r--r--ydb/core/kqp/ut/kqp_ne_effects_ut.cpp64
-rw-r--r--ydb/core/kqp/ut/kqp_ne_flowcontrol_ut.cpp15
-rw-r--r--ydb/core/kqp/ut/kqp_ne_perf_ut.cpp64
-rw-r--r--ydb/core/kqp/ut/kqp_ne_ut.cpp339
-rw-r--r--ydb/core/kqp/ut/kqp_olap_ut.cpp105
-rw-r--r--ydb/core/kqp/ut/kqp_params_ut.cpp4
-rw-r--r--ydb/core/kqp/ut/kqp_query_ut.cpp2
-rw-r--r--ydb/core/kqp/ut/kqp_scan_ut.cpp328
-rw-r--r--ydb/core/kqp/ut/kqp_service_ut.cpp24
-rw-r--r--ydb/core/kqp/ut/kqp_stats_ut.cpp49
-rw-r--r--ydb/core/kqp/ut/kqp_sys_view_ut.cpp4
-rw-r--r--ydb/core/kqp/ut/kqp_tx_ut.cpp61
-rw-r--r--ydb/core/kqp/ut/kqp_types_arrow_ut.cpp3
-rw-r--r--ydb/core/kqp/ut/kqp_write_ut.cpp24
-rw-r--r--ydb/core/kqp/ut/kqp_yql_ut.cpp60
-rw-r--r--ydb/core/testlib/test_client.h5
-rw-r--r--ydb/core/tx/columnshard/ut_columnshard_tiers.cpp2
-rw-r--r--ydb/core/tx/datashard/datashard_ut_kqp_errors.cpp1
-rw-r--r--ydb/core/tx/datashard/datashard_ut_order.cpp30
-rw-r--r--ydb/core/tx/datashard/datashard_ut_snapshot.cpp17
23 files changed, 607 insertions, 710 deletions
diff --git a/ydb/core/kqp/ut/common/kqp_ut_common.h b/ydb/core/kqp/ut/common/kqp_ut_common.h
index 87f6c8f9762..48c4e99f71a 100644
--- a/ydb/core/kqp/ut/common/kqp_ut_common.h
+++ b/ydb/core/kqp/ut/common/kqp_ut_common.h
@@ -82,15 +82,10 @@ struct TKikimrSettings: public TTestFeatureFlagsHolder<TKikimrSettings> {
TKikimrSettings()
{
// default value for tests, can be overwritten by SetFeatureFlags()
- SetEnableKqpSessionActor(false);
+ Y_VERIFY(AppConfig.MutableTableServiceConfig()->GetEnableKqpSessionActor());
this->SetEnableKqpScanQueryStreamLookup(true);
}
- TKikimrSettings& SetEnableKqpSessionActor(bool enable) {
- AppConfig.MutableTableServiceConfig()->SetEnableKqpSessionActor(enable);
- return *this;
- }
-
TKikimrSettings& SetAppConfig(const NKikimrConfig::TAppConfig& value) { AppConfig = value; return *this; }
TKikimrSettings& SetFeatureFlags(const NKikimrConfig::TFeatureFlags& value) { FeatureFlags = value; return *this; }
TKikimrSettings& SetPQConfig(const NKikimrPQ::TPQConfig& value) { PQConfig = value; return *this; };
@@ -160,12 +155,11 @@ private:
THolder<NYdb::TDriver> Driver;
};
-inline TKikimrRunner KikimrRunnerEnableSessionActor(bool enable, TVector<NKikimrKqp::TKqpSetting> kqpSettings = {},
+inline TKikimrRunner DefaultKikimrRunner(TVector<NKikimrKqp::TKqpSetting> kqpSettings = {},
const NKikimrConfig::TAppConfig& appConfig = {})
{
auto settings = TKikimrSettings()
.SetAppConfig(appConfig)
- .SetEnableKqpSessionActor(enable)
.SetKqpSettings(kqpSettings);
return TKikimrRunner{settings};
diff --git a/ydb/core/kqp/ut/kqp_explain_ut.cpp b/ydb/core/kqp/ut/kqp_explain_ut.cpp
index 884bea6d2d7..22a5b9dc408 100644
--- a/ydb/core/kqp/ut/kqp_explain_ut.cpp
+++ b/ydb/core/kqp/ut/kqp_explain_ut.cpp
@@ -60,8 +60,8 @@ bool ValidatePlanNodeIds(const NJson::TJsonValue& plan) {
Y_UNIT_TEST_SUITE(KqpExplain) {
- Y_UNIT_TEST_TWIN(Explain, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(Explain) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
TStreamExecScanQuerySettings settings;
settings.Explain(true);
@@ -90,8 +90,8 @@ Y_UNIT_TEST_SUITE(KqpExplain) {
UNIT_ASSERT(right.IsDefined());
}
- Y_UNIT_TEST_TWIN(ExplainStream, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(ExplainStream) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
TStreamExecScanQuerySettings settings;
settings.Explain(true);
@@ -119,8 +119,8 @@ Y_UNIT_TEST_SUITE(KqpExplain) {
UNIT_ASSERT(right.IsDefined());
}
- Y_UNIT_TEST_TWIN(ExplainScanQueryWithParams, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(ExplainScanQueryWithParams) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
TStreamExecScanQuerySettings settings;
settings.Explain(true);
@@ -135,8 +135,8 @@ Y_UNIT_TEST_SUITE(KqpExplain) {
UNIT_ASSERT_C(it.IsSuccess(), it.GetIssues().ToString());
}
- Y_UNIT_TEST_TWIN(AggGroupLimit, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(AggGroupLimit) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
TStreamExecScanQuerySettings settings;
settings.Explain(true);
@@ -169,8 +169,8 @@ Y_UNIT_TEST_SUITE(KqpExplain) {
"{_yql_agg_0: MIN(item.Message),_yql_agg_1: MAX(item.Message)}");
}
- Y_UNIT_TEST_TWIN(ComplexJoin, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(ComplexJoin) {
+ auto kikimr = DefaultKikimrRunner();
CreateSampleTables(kikimr);
auto db = kikimr.GetTableClient();
TStreamExecScanQuerySettings settings;
@@ -211,8 +211,8 @@ Y_UNIT_TEST_SUITE(KqpExplain) {
UNIT_ASSERT(right.IsDefined());
}
- Y_UNIT_TEST_TWIN(PrecomputeRange, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(PrecomputeRange) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
TStreamExecScanQuerySettings settings;
settings.Explain(true);
@@ -240,8 +240,8 @@ Y_UNIT_TEST_SUITE(KqpExplain) {
UNIT_ASSERT(readRanges[0] == "Key [150, 266]");
}
- Y_UNIT_TEST_TWIN(CompoundKeyRange, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(CompoundKeyRange) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
TStreamExecScanQuerySettings settings;
settings.Explain(true);
@@ -269,8 +269,8 @@ Y_UNIT_TEST_SUITE(KqpExplain) {
UNIT_ASSERT(lookup.at("ReadRange").GetArraySafe()[0] == "App (new_app_1)");
}
- Y_UNIT_TEST_TWIN(SortStage, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(SortStage) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
TStreamExecScanQuerySettings settings;
settings.Explain(true);
@@ -292,8 +292,8 @@ Y_UNIT_TEST_SUITE(KqpExplain) {
UNIT_ASSERT(scanSort.IsDefined());
}
- Y_UNIT_TEST_TWIN(LimitOffset, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(LimitOffset) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
TStreamExecScanQuerySettings settings;
settings.Explain(true);
@@ -317,8 +317,8 @@ Y_UNIT_TEST_SUITE(KqpExplain) {
UNIT_ASSERT(offset.IsDefined());
}
- Y_UNIT_TEST_TWIN(SelfJoin3xSameLabels, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(SelfJoin3xSameLabels) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
TStreamExecScanQuerySettings settings;
settings.Explain(true);
@@ -353,8 +353,8 @@ Y_UNIT_TEST_SUITE(KqpExplain) {
UNIT_ASSERT(join2.IsDefined());
}
- Y_UNIT_TEST_TWIN(PureExpr, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(PureExpr) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
TStreamExecScanQuerySettings settings;
settings.Explain(true);
@@ -376,12 +376,12 @@ Y_UNIT_TEST_SUITE(KqpExplain) {
UNIT_ASSERT(constExpr.IsDefined());
}
- Y_UNIT_TEST_TWIN(MultiUsedStage, UseSessionActor) {
+ Y_UNIT_TEST(MultiUsedStage) {
NKikimrConfig::TAppConfig appCfg;
auto* spilling = appCfg.MutableTableServiceConfig()->MutableSpillingServiceConfig()->MutableLocalFileConfig();
spilling->SetEnable(true);
spilling->SetRoot("./spilling/");
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, appCfg);
+ auto kikimr = DefaultKikimrRunner({}, appCfg);
auto db = kikimr.GetTableClient();
TStreamExecScanQuerySettings settings;
@@ -413,8 +413,8 @@ Y_UNIT_TEST_SUITE(KqpExplain) {
UNIT_ASSERT(containCte);
}
- Y_UNIT_TEST_TWIN(SqlIn, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(SqlIn) {
+ auto kikimr = DefaultKikimrRunner();
CreateSampleTables(kikimr);
TStreamExecScanQuerySettings settings;
@@ -441,8 +441,8 @@ Y_UNIT_TEST_SUITE(KqpExplain) {
UNIT_ASSERT_EQUAL(unionNode.GetMap().at("Plans").GetArraySafe().size(), 4);
}
- Y_UNIT_TEST_TWIN(ExplainDataQueryOldEngine, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(ExplainDataQueryOldEngine) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -458,8 +458,8 @@ Y_UNIT_TEST_SUITE(KqpExplain) {
UNIT_ASSERT_EQUAL(plan.GetMapSafe().at("tables").GetArraySafe()[0].GetMapSafe().at("name").GetStringSafe(), "/Root/KeyValue");
}
- Y_UNIT_TEST_TWIN(ExplainDataQueryNewEngine, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(ExplainDataQueryNewEngine) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -484,8 +484,8 @@ Y_UNIT_TEST_SUITE(KqpExplain) {
UNIT_ASSERT_EQUAL(node.GetMapSafe().at("Table").GetStringSafe(), "KeyValue");
}
- Y_UNIT_TEST_TWIN(FewEffects, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(FewEffects) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -538,8 +538,8 @@ Y_UNIT_TEST_SUITE(KqpExplain) {
UNIT_ASSERT_VALUES_EQUAL(counter["Lookup"], lookupsCount);
}
- Y_UNIT_TEST_TWIN(ExplainDataQueryWithParams, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(ExplainDataQueryWithParams) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -556,8 +556,8 @@ Y_UNIT_TEST_SUITE(KqpExplain) {
UNIT_ASSERT_VALUES_EQUAL_C(result2.GetStatus(), EStatus::SUCCESS, result2.GetIssues().ToString());
}
- Y_UNIT_TEST_TWIN(FullOuterJoin, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(FullOuterJoin) {
+ auto kikimr = DefaultKikimrRunner();
CreateSampleTables(kikimr);
TStreamExecScanQuerySettings settings;
@@ -586,8 +586,8 @@ Y_UNIT_TEST_SUITE(KqpExplain) {
UNIT_ASSERT(right.IsDefined());
}
- Y_UNIT_TEST_TWIN(ReadTableRangesFullScan, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(ReadTableRangesFullScan) {
+ auto kikimr = DefaultKikimrRunner();
TStreamExecScanQuerySettings settings;
settings.Explain(true);
auto db = kikimr.GetTableClient();
@@ -650,8 +650,8 @@ Y_UNIT_TEST_SUITE(KqpExplain) {
}
}
- Y_UNIT_TEST_TWIN(ReadTableRanges, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(ReadTableRanges) {
+ auto kikimr = DefaultKikimrRunner();
CreateSampleTables(kikimr);
TStreamExecScanQuerySettings settings;
@@ -679,8 +679,8 @@ Y_UNIT_TEST_SUITE(KqpExplain) {
UNIT_ASSERT(count.IsDefined());
}
- Y_UNIT_TEST_TWIN(Predicates, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(Predicates) {
+ auto kikimr = DefaultKikimrRunner();
TStreamExecScanQuerySettings settings;
settings.Explain(true);
@@ -749,8 +749,8 @@ Y_UNIT_TEST_SUITE(KqpExplain) {
}
}
- Y_UNIT_TEST_TWIN(MergeConnection, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(MergeConnection) {
+ auto kikimr = DefaultKikimrRunner();
TStreamExecScanQuerySettings settings;
settings.Explain(true);
diff --git a/ydb/core/kqp/ut/kqp_limits_ut.cpp b/ydb/core/kqp/ut/kqp_limits_ut.cpp
index 049a0854f17..75839354bb1 100644
--- a/ydb/core/kqp/ut/kqp_limits_ut.cpp
+++ b/ydb/core/kqp/ut/kqp_limits_ut.cpp
@@ -66,7 +66,6 @@ Y_UNIT_TEST_SUITE(KqpLimits) {
Y_UNIT_TEST(DatashardProgramSize) {
auto app = NKikimrConfig::TAppConfig();
app.MutableTableServiceConfig()->MutableResourceManager()->SetMkqlLightProgramMemoryLimit(1'000'000'000);
- app.MutableTableServiceConfig()->SetEnableKqpSessionActor(false);
TKikimrRunner kikimr(app);
CreateLargeTable(kikimr, 0, 0, 0);
@@ -103,7 +102,8 @@ Y_UNIT_TEST_SUITE(KqpLimits) {
SELECT * FROM AS_TABLE($rows);
)"), TTxControl::BeginTx().CommitTx(), paramsBuilder.Build()).ExtractValueSync();
result.GetIssues().PrintTo(Cerr);
- UNIT_ASSERT_VALUES_EQUAL(result.GetStatus(), EStatus::GENERIC_ERROR);
+ // UNIT_ASSERT_VALUES_EQUAL(result.GetStatus(), EStatus::PRECONDITION_FAILED);
+ UNIT_ASSERT_VALUES_EQUAL(result.GetStatus(), EStatus::ABORTED);
UNIT_ASSERT(HasIssue(result.GetIssues(), NKikimrIssues::TIssuesIds::SHARD_PROGRAM_SIZE_EXCEEDED));
}
@@ -111,7 +111,6 @@ Y_UNIT_TEST_SUITE(KqpLimits) {
auto app = NKikimrConfig::TAppConfig();
auto& queryLimits = *app.MutableTableServiceConfig()->MutableQueryLimits();
queryLimits.MutablePhaseLimits()->SetComputeNodeMemoryLimitBytes(1'000'000'000);
- app.MutableTableServiceConfig()->SetEnableKqpSessionActor(false);
TKikimrRunner kikimr(app);
CreateLargeTable(kikimr, 100, 10, 1'000'000, 1, 2);
@@ -141,7 +140,7 @@ Y_UNIT_TEST_SUITE(KqpLimits) {
SELECT * FROM `/Root/LargeTable`;
)"), TTxControl::BeginTx().CommitTx()).ExtractValueSync();
result.GetIssues().PrintTo(Cerr);
- UNIT_ASSERT_VALUES_EQUAL(result.GetStatus(), EStatus::UNDETERMINED);
+ UNIT_ASSERT_VALUES_EQUAL(result.GetStatus(), EStatus::PRECONDITION_FAILED);
UNIT_ASSERT(HasIssue(result.GetIssues(), NYql::TIssuesIds::KIKIMR_RESULT_UNAVAILABLE));
}
@@ -149,7 +148,6 @@ Y_UNIT_TEST_SUITE(KqpLimits) {
auto app = NKikimrConfig::TAppConfig();
app.MutableTableServiceConfig()->MutableResourceManager()->SetMkqlLightProgramMemoryLimit(1'000'000'000);
app.MutableTableServiceConfig()->SetCompileTimeoutMs(TDuration::Minutes(5).MilliSeconds());
- app.MutableTableServiceConfig()->SetEnableKqpSessionActor(false);
TKikimrRunner kikimr(app);
CreateLargeTable(kikimr, 0, 0, 0);
@@ -182,7 +180,8 @@ Y_UNIT_TEST_SUITE(KqpLimits) {
auto result = session.ExecuteDataQuery(query, TTxControl::BeginTx().CommitTx()).ExtractValueSync();
result.GetIssues().PrintTo(Cerr);
- UNIT_ASSERT_VALUES_EQUAL_C(result.GetStatus(), EStatus::GENERIC_ERROR, result.GetIssues().ToString());
+ //UNIT_ASSERT_VALUES_EQUAL_C(result.GetStatus(), EStatus::PRECONDITION_FAILED, result.GetIssues().ToString());
+ UNIT_ASSERT_VALUES_EQUAL_C(result.GetStatus(), EStatus::ABORTED, result.GetIssues().ToString());
UNIT_ASSERT(HasIssue(result.GetIssues(), NKikimrIssues::TIssuesIds::SHARD_PROGRAM_SIZE_EXCEEDED));
}
@@ -292,7 +291,6 @@ Y_UNIT_TEST_SUITE(KqpLimits) {
NKikimrConfig::TAppConfig appConfig;
auto& queryLimits = *appConfig.MutableTableServiceConfig()->MutableQueryLimits();
queryLimits.MutablePhaseLimits()->SetAffectedShardsLimit(20);
- appConfig.MutableTableServiceConfig()->SetEnableKqpSessionActor(false);
TKikimrRunner kikimr(appConfig);
@@ -334,7 +332,6 @@ Y_UNIT_TEST_SUITE(KqpLimits) {
NKikimrConfig::TAppConfig appConfig;
auto& queryLimits = *appConfig.MutableTableServiceConfig()->MutableQueryLimits();
queryLimits.MutablePhaseLimits()->SetReadsetCountLimit(50);
- appConfig.MutableTableServiceConfig()->SetEnableKqpSessionActor(false);
TKikimrRunner kikimr(appConfig);
CreateLargeTable(kikimr, 10, 10, 100);
@@ -367,8 +364,7 @@ Y_UNIT_TEST_SUITE(KqpLimits) {
auto serverSettings = TKikimrSettings()
.SetAppConfig(appConfig)
- .SetEnableMvccSnapshotReads(false)
- .SetEnableKqpSessionActor(false);
+ .SetEnableMvccSnapshotReads(false);
TKikimrRunner kikimr(serverSettings);
CreateLargeTable(kikimr, 20, 10, 1'000'000, 1);
@@ -400,7 +396,6 @@ Y_UNIT_TEST_SUITE(KqpLimits) {
appConfig.MutableTableServiceConfig()->MutableResourceManager()->SetMkqlLightProgramMemoryLimit(1'000'000'000);
auto& queryLimits = *appConfig.MutableTableServiceConfig()->MutableQueryLimits();
queryLimits.MutablePhaseLimits()->SetComputeNodeMemoryLimitBytes(100'000'000);
- appConfig.MutableTableServiceConfig()->SetEnableKqpSessionActor(false);
TKikimrRunner kikimr(appConfig);
@@ -449,7 +444,6 @@ Y_UNIT_TEST_SUITE(KqpLimits) {
Y_UNIT_TEST(QueryExecTimeout) {
NKikimrConfig::TAppConfig appConfig;
appConfig.MutableTableServiceConfig()->MutableResourceManager()->SetMkqlLightProgramMemoryLimit(10'000'000'000);
- appConfig.MutableTableServiceConfig()->SetEnableKqpSessionActor(false);
TKikimrRunner kikimr(appConfig);
diff --git a/ydb/core/kqp/ut/kqp_ne_effects_ut.cpp b/ydb/core/kqp/ut/kqp_ne_effects_ut.cpp
index 7991512f5ef..5ceb9149976 100644
--- a/ydb/core/kqp/ut/kqp_ne_effects_ut.cpp
+++ b/ydb/core/kqp/ut/kqp_ne_effects_ut.cpp
@@ -9,8 +9,8 @@ using namespace NYdb;
using namespace NYdb::NTable;
Y_UNIT_TEST_SUITE(KqpNewEngineEffects) {
- Y_UNIT_TEST_TWIN(InsertAbort_Literal_Success, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(InsertAbort_Literal_Success) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -31,8 +31,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngineEffects) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(InsertAbort_Literal_Duplicates, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(InsertAbort_Literal_Duplicates) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -53,8 +53,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngineEffects) {
CompareYson(R"([])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(InsertAbort_Literal_Conflict, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(InsertAbort_Literal_Conflict) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -77,8 +77,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngineEffects) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(InsertAbort_Params_Success, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(InsertAbort_Params_Success) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -114,8 +114,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngineEffects) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(InsertAbort_Params_Duplicates, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(InsertAbort_Params_Duplicates) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -158,8 +158,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngineEffects) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(InsertAbort_Params_Conflict, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(InsertAbort_Params_Conflict) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -197,8 +197,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngineEffects) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(InsertAbort_Select_Success, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(InsertAbort_Select_Success) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -234,8 +234,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngineEffects) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(InsertAbort_Select_Duplicates, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(InsertAbort_Select_Duplicates) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -274,8 +274,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngineEffects) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(InsertAbort_Select_Conflict, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(InsertAbort_Select_Conflict) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -313,8 +313,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngineEffects) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(InsertRevert_Literal_Success, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(InsertRevert_Literal_Success) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -335,8 +335,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngineEffects) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(InsertRevert_Literal_Duplicates, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(InsertRevert_Literal_Duplicates) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -355,8 +355,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngineEffects) {
CompareYson(R"([])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(InsertRevert_Literal_Conflict, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(InsertRevert_Literal_Conflict) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -377,8 +377,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngineEffects) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(UpdateOn_Literal, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(UpdateOn_Literal) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -404,8 +404,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngineEffects) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(UpdateOn_Params, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(UpdateOn_Params) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -445,8 +445,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngineEffects) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(UpdateOn_Select, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(UpdateOn_Select) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -476,8 +476,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngineEffects) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(DeletePkPrefixWithIndex, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(DeletePkPrefixWithIndex) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
diff --git a/ydb/core/kqp/ut/kqp_ne_flowcontrol_ut.cpp b/ydb/core/kqp/ut/kqp_ne_flowcontrol_ut.cpp
index 46e107c2408..45a675b0abf 100644
--- a/ydb/core/kqp/ut/kqp_ne_flowcontrol_ut.cpp
+++ b/ydb/core/kqp/ut/kqp_ne_flowcontrol_ut.cpp
@@ -49,7 +49,7 @@ void CreateSampleTables(TKikimrRunner& kikimr) {
Y_UNIT_TEST_SUITE(KqpFlowControl) {
-void DoFlowControlTest(ui64 limit, bool hasBlockedByCapacity, bool useSessionActor) {
+void DoFlowControlTest(ui64 limit, bool hasBlockedByCapacity) {
NKikimrConfig::TAppConfig appCfg;
appCfg.MutableTableServiceConfig()->MutableResourceManager()->SetChannelBufferSize(limit);
appCfg.MutableTableServiceConfig()->MutableResourceManager()->SetMinChannelBufferSize(limit);
@@ -59,7 +59,6 @@ void DoFlowControlTest(ui64 limit, bool hasBlockedByCapacity, bool useSessionAct
// TODO: KIKIMR-14294
auto kikimrSettings = TKikimrSettings()
.SetAppConfig(appCfg)
- .SetEnableKqpSessionActor(useSessionActor)
.SetKqpSettings({})
.SetEnableKqpScanQueryStreamLookup(false);
TKikimrRunner kikimr{kikimrSettings};
@@ -111,16 +110,16 @@ void DoFlowControlTest(ui64 limit, bool hasBlockedByCapacity, bool useSessionAct
UNIT_ASSERT_EQUAL(hasBlockedByCapacity, writesBlockedNoSpace > 0);
}
-Y_UNIT_TEST_TWIN(FlowControl_Unlimited, UseSessionActor) {
- DoFlowControlTest(100ul << 20, false, UseSessionActor);
+Y_UNIT_TEST(FlowControl_Unlimited) {
+ DoFlowControlTest(100ul << 20, false);
}
-Y_UNIT_TEST_TWIN(FlowControl_BigLimit, UseSessionActor) {
- DoFlowControlTest(1ul << 10, false, UseSessionActor);
+Y_UNIT_TEST(FlowControl_BigLimit) {
+ DoFlowControlTest(1ul << 10, false);
}
-Y_UNIT_TEST_TWIN(FlowControl_SmallLimit, UseSessionActor) {
- DoFlowControlTest(1ul, true, UseSessionActor);
+Y_UNIT_TEST(FlowControl_SmallLimit) {
+ DoFlowControlTest(1ul, true);
}
//Y_UNIT_TEST(SlowClient) {
diff --git a/ydb/core/kqp/ut/kqp_ne_perf_ut.cpp b/ydb/core/kqp/ut/kqp_ne_perf_ut.cpp
index 8ee0d203480..5389d273cca 100644
--- a/ydb/core/kqp/ut/kqp_ne_perf_ut.cpp
+++ b/ydb/core/kqp/ut/kqp_ne_perf_ut.cpp
@@ -120,8 +120,8 @@ TParams BuildInsertIndexParams(TTableClient& client) {
} // namespace
Y_UNIT_TEST_SUITE(KqpPerf) {
- Y_UNIT_TEST_TWIN(Upsert, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(Upsert) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -153,8 +153,8 @@ Y_UNIT_TEST_SUITE(KqpPerf) {
}
}
- Y_UNIT_TEST_TWIN(Replace, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(Replace) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -186,8 +186,8 @@ Y_UNIT_TEST_SUITE(KqpPerf) {
}
}
- Y_UNIT_TEST_TWIN(UpdateOn, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(UpdateOn) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -219,8 +219,8 @@ Y_UNIT_TEST_SUITE(KqpPerf) {
}
}
- Y_UNIT_TEST_TWIN(Insert, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(Insert) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -252,8 +252,8 @@ Y_UNIT_TEST_SUITE(KqpPerf) {
}
}
- Y_UNIT_TEST_TWIN(DeleteOn, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(DeleteOn) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -285,8 +285,8 @@ Y_UNIT_TEST_SUITE(KqpPerf) {
}
}
- Y_UNIT_TEST_TWIN(Update, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(Update) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -320,8 +320,8 @@ Y_UNIT_TEST_SUITE(KqpPerf) {
}
}
- Y_UNIT_TEST_TWIN(Delete, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(Delete) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -356,8 +356,8 @@ Y_UNIT_TEST_SUITE(KqpPerf) {
}
}
- Y_UNIT_TEST_TWIN(IndexUpsert, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(IndexUpsert) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
CreateSampleTablesWithIndex(session);
@@ -379,8 +379,8 @@ Y_UNIT_TEST_SUITE(KqpPerf) {
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases().size(), 4);
}
- Y_UNIT_TEST_TWIN(IndexReplace, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(IndexReplace) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
CreateSampleTablesWithIndex(session);
@@ -402,8 +402,8 @@ Y_UNIT_TEST_SUITE(KqpPerf) {
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases().size(), 4);
}
- Y_UNIT_TEST_TWIN(IndexUpdateOn, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(IndexUpdateOn) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
CreateSampleTablesWithIndex(session);
@@ -425,8 +425,8 @@ Y_UNIT_TEST_SUITE(KqpPerf) {
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases().size(), 4);
}
- Y_UNIT_TEST_TWIN(IndexDeleteOn, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(IndexDeleteOn) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
CreateSampleTablesWithIndex(session);
@@ -448,8 +448,8 @@ Y_UNIT_TEST_SUITE(KqpPerf) {
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases().size(), 4);
}
- Y_UNIT_TEST_TWIN(IndexInsert, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(IndexInsert) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
CreateSampleTablesWithIndex(session);
@@ -471,8 +471,8 @@ Y_UNIT_TEST_SUITE(KqpPerf) {
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases().size(), 5);
}
- Y_UNIT_TEST_TWIN(IdxLookupJoin, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(IdxLookupJoin) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -497,8 +497,8 @@ Y_UNIT_TEST_SUITE(KqpPerf) {
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases().size(), 3);
}
- Y_UNIT_TEST_TWIN(IdxLookupJoinThreeWay, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(IdxLookupJoinThreeWay) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -524,8 +524,8 @@ Y_UNIT_TEST_SUITE(KqpPerf) {
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases().size(), 5);
}
- Y_UNIT_TEST_TWIN(ComputeLength, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(ComputeLength) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -542,8 +542,8 @@ Y_UNIT_TEST_SUITE(KqpPerf) {
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases().size(), 1);
}
- Y_UNIT_TEST_TWIN(AggregateToScalar, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(AggregateToScalar) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
diff --git a/ydb/core/kqp/ut/kqp_ne_ut.cpp b/ydb/core/kqp/ut/kqp_ne_ut.cpp
index 833e9b6888d..d8f73e4c57f 100644
--- a/ydb/core/kqp/ut/kqp_ne_ut.cpp
+++ b/ydb/core/kqp/ut/kqp_ne_ut.cpp
@@ -8,9 +8,8 @@ using namespace NYdb;
using namespace NYdb::NTable;
Y_UNIT_TEST_SUITE(KqpNewEngine) {
- Y_UNIT_TEST_TWIN(Select1, UseSessionActor) {
+ Y_UNIT_TEST(Select1) {
auto settings = TKikimrSettings()
- .SetEnableKqpSessionActor(UseSessionActor)
.SetWithSampleTables(false);
auto kikimr = TKikimrRunner{settings};
auto db = kikimr.GetTableClient();
@@ -26,9 +25,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
)", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(SimpleUpsertSelect, UseSessionActor) {
+ Y_UNIT_TEST(SimpleUpsertSelect) {
auto settings = TKikimrSettings()
- .SetEnableKqpSessionActor(UseSessionActor)
.SetWithSampleTables(false);
auto kikimr = TKikimrRunner{settings};
auto db = kikimr.GetTableClient();
@@ -66,8 +64,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
])", FormatResultSetYson(selectResult.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(PkSelect1, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(PkSelect1) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -120,8 +118,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
UNIT_ASSERT_VALUES_EQUAL(1, stats.query_phases()[0].table_access()[0].partitions_count());
}
- Y_UNIT_TEST_TWIN(PkSelect2, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(PkSelect2) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -158,8 +156,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
CompareYson(R"([])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(PkRangeSelect1, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(PkRangeSelect1) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -191,8 +189,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(PkRangeSelect2, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(PkRangeSelect2) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -225,8 +223,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(PkRangeSelect3, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(PkRangeSelect3) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -255,8 +253,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(PkRangeSelect4, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(PkRangeSelect4) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -282,8 +280,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(MultiSelect, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(MultiSelect) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -313,8 +311,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(MultiOutput, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(MultiOutput) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -337,8 +335,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
])", FormatResultSetYson(result.GetResultSet(1)));
}
- Y_UNIT_TEST_TWIN(InShardsWrite, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(InShardsWrite) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -365,8 +363,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
)", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(ShuffleWrite, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(ShuffleWrite) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -393,8 +391,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
)", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(KeyColumnOrder, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(KeyColumnOrder) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
// Please do not change the name of columns here
@@ -439,8 +437,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
}
}
- Y_UNIT_TEST_TWIN(KeyColumnOrder2, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(KeyColumnOrder2) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
{
@@ -470,8 +468,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
}
}
- Y_UNIT_TEST_TWIN(BlindWrite, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(BlindWrite) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -495,8 +493,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
)", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(BlindWriteParameters, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(BlindWriteParameters) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -542,8 +540,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
)", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(BlindWriteListParameter, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(BlindWriteListParameter) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -589,8 +587,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
)", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(BatchUpload, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(BatchUpload) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -668,8 +666,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
}
#if !defined(_ubsan_enabled_)
- Y_UNIT_TEST_TWIN(Aggregate, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(Aggregate) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
auto result = session.ExecuteDataQuery(R"(
@@ -683,8 +681,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
)", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(AggregateTuple, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(AggregateTuple) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
auto result = session.ExecuteDataQuery(R"(
@@ -701,8 +699,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
}
#endif
- Y_UNIT_TEST_TWIN(PureExpr, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(PureExpr) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -720,8 +718,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
UNIT_ASSERT(stats.query_phases(0).table_access().size() == 0);
}
- Y_UNIT_TEST_TWIN(MultiStatement, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(MultiStatement) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -743,8 +741,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
UNIT_ASSERT(stats.query_phases(0).table_access().size() == 0);
}
- Y_UNIT_TEST_TWIN(MultiStatementMixPure, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(MultiStatementMixPure) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
auto result = session.ExecuteDataQuery(R"(
@@ -760,8 +758,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
CompareYson(R"([[[101u]]])", FormatResultSetYson(result.GetResultSet(3)));
}
- Y_UNIT_TEST_TWIN(LocksSingleShard, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(LocksSingleShard) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session1 = db.CreateSession().GetValueSync().GetSession();
@@ -792,8 +790,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
}
}
- Y_UNIT_TEST_TWIN(LocksMultiShard, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(LocksMultiShard) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session1 = db.CreateSession().GetValueSync().GetSession();
@@ -824,8 +822,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
}
}
- Y_UNIT_TEST_TWIN(LocksMultiShardOk, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(LocksMultiShardOk) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -842,8 +840,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
AssertSuccessResult(result);
}
- Y_UNIT_TEST_TWIN(LocksEffects, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(LocksEffects) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session1 = db.CreateSession().GetValueSync().GetSession();
@@ -877,8 +875,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(LocksNoMutations, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(LocksNoMutations) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -897,8 +895,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
CompareYson(R"([[42]])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(LocksNoMutationsSharded, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(LocksNoMutationsSharded) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -917,8 +915,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
CompareYson(R"([[42]])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(BrokenLocksAtROTx, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(BrokenLocksAtROTx) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -951,8 +949,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
}
}
- Y_UNIT_TEST_TWIN(BrokenLocksAtROTxSharded, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(BrokenLocksAtROTxSharded) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -985,8 +983,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
}
}
- Y_UNIT_TEST_TWIN(BrokenLocksOnUpdate, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(BrokenLocksOnUpdate) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -1021,8 +1019,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
CompareYson(R"([])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(DeferredEffects, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(DeferredEffects) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -1082,9 +1080,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(PureTxMixedWithDeferred, UseSessionActor) {
- auto settings = TKikimrSettings()
- .SetEnableKqpSessionActor(UseSessionActor);
+ Y_UNIT_TEST(PureTxMixedWithDeferred) {
+ auto settings = TKikimrSettings();
auto kikimr = TKikimrRunner{settings};
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -1106,8 +1103,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
)", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(PrunePartitionsByLiteral, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(PrunePartitionsByLiteral) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -1135,8 +1132,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
UNIT_ASSERT(stats.query_phases(0).duration_us() > 0);
}
- Y_UNIT_TEST_TWIN(PrunePartitionsByExpr, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(PrunePartitionsByExpr) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -1172,8 +1169,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
UNIT_ASSERT(stats.query_phases(1).duration_us() > 0);
}
- Y_UNIT_TEST_TWIN(PruneWritePartitions, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(PruneWritePartitions) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -1215,14 +1212,14 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(Truncated, UseSessionActor) {
+ Y_UNIT_TEST(Truncated) {
TVector<NKikimrKqp::TKqpSetting> settings;
NKikimrKqp::TKqpSetting setting;
setting.SetName("_ResultRowsLimit");
setting.SetValue("5");
settings.push_back(setting);
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, settings);
+ auto kikimr = DefaultKikimrRunner(settings);
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -1236,8 +1233,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
UNIT_ASSERT(result.GetResultSet(0).Truncated());
}
- Y_UNIT_TEST_TWIN(Replace, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(Replace) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -1290,8 +1287,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
UNIT_ASSERT_C(!result.IsSuccess(), result.GetIssues().ToString());
}
- Y_UNIT_TEST_TWIN(Join, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(Join) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -1313,8 +1310,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(JoinWithParams, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(JoinWithParams) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -1344,8 +1341,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(JoinIdxLookup, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(JoinIdxLookup) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -1390,8 +1387,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(2).table_access(0).reads().rows(), 4);
}
- Y_UNIT_TEST_TWIN(LeftSemiJoin, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(LeftSemiJoin) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -1425,8 +1422,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(JoinPure, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(JoinPure) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -1471,8 +1468,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(JoinPureUncomparableKeys, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(JoinPureUncomparableKeys) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -1494,8 +1491,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
CompareYson(R"([])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(SelfJoin, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(SelfJoin) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -1513,8 +1510,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(Update, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(Update) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -1557,8 +1554,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(Delete, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(Delete) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -1601,8 +1598,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(DeleteOn, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(DeleteOn) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -1645,8 +1642,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(MultiEffects, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(MultiEffects) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -1678,8 +1675,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(UpdateFromParams, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(UpdateFromParams) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -1725,8 +1722,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(PruneEffectPartitions, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(PruneEffectPartitions) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -1778,8 +1775,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
])", FormatResultSetYson(it.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(DecimalColumn, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(DecimalColumn) {
+ auto kikimr = DefaultKikimrRunner();
TTableClient client{kikimr.GetDriver()};
auto session = client.CreateSession().GetValueSync().GetSession();
@@ -1821,8 +1818,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(LocksInRoTx, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(LocksInRoTx) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -1846,8 +1843,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
UNIT_ASSERT_C(ret.IsSuccess(), ret.GetIssues().ToString());
}
- Y_UNIT_TEST_TWIN(ItemsLimit, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(ItemsLimit) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -1920,8 +1917,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
// )");
}
- Y_UNIT_TEST_TWIN(OnlineRO_Consistent, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(OnlineRO_Consistent) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -1942,8 +1939,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
)", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(OnlineRO_Inconsistent, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(OnlineRO_Inconsistent) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -1965,8 +1962,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
)", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(StaleRO, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(StaleRO) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -2053,8 +2050,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
)", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(StaleRO_Immediate, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(StaleRO_Immediate) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -2075,8 +2072,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
)", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(ReadRangeWithParams, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(ReadRangeWithParams) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -2093,8 +2090,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
UNIT_ASSERT(range.IsDefined());
}
- Y_UNIT_TEST_TWIN(Nondeterministic, UseSessionActor) { // TODO: KIKIMR-4759
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(Nondeterministic) { // TODO: KIKIMR-4759
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -2117,8 +2114,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
UNIT_ASSERT_VALUES_EQUAL(result.GetResultSet(0).RowsCount(), 1);
}
- Y_UNIT_TEST_TWIN(ScalarFunctions, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(ScalarFunctions) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -2302,8 +2299,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
}
}
- Y_UNIT_TEST_TWIN(DeleteWithBuiltin, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(DeleteWithBuiltin) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -2319,8 +2316,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
UNIT_ASSERT_EQUAL(stats.query_phases().size(), 2);
}
- Y_UNIT_TEST_TWIN(MultiEffectsOnSameTable, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(MultiEffectsOnSameTable) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -2345,8 +2342,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
CompareYson("[[[100500u];[100]]]", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(MultiUsagePrecompute, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(MultiUsagePrecompute) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -2372,8 +2369,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
CompareYson("[[[1]];[[1]];[[1]];[[2]];[[2]]]", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(SqlInFromCompact, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(SqlInFromCompact) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -2433,8 +2430,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
UNIT_ASSERT_C(result.IsSuccess(), result.GetIssues().ToString());
}
- Y_UNIT_TEST_TWIN(PrecomputeKey, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(PrecomputeKey) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -2454,8 +2451,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
CompareYson(R"([[["Value21"]]])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(UnionAllPure, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(UnionAllPure) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -2482,8 +2479,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(JoinWithPrecompute, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(JoinWithPrecompute) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -2514,8 +2511,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
CompareYson(R"([[106u;[101u];["One"]]])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(JoinProjectMulti, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(JoinProjectMulti) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -2538,8 +2535,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(JoinMultiConsumer, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(JoinMultiConsumer) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -2585,8 +2582,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(UpsertEmptyInput, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(UpsertEmptyInput) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -2619,8 +2616,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
UNIT_ASSERT_C(result.IsSuccess(), result.GetIssues().ToString());
}
- Y_UNIT_TEST_TWIN(DeleteByKey, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(DeleteByKey) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -2714,8 +2711,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(DeleteWithInputMultiConsumption, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(DeleteWithInputMultiConsumption) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -2758,8 +2755,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(DeleteWithInputMultiConsumptionLimit, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(DeleteWithInputMultiConsumptionLimit) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -2796,8 +2793,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
}
// https://st.yandex-team.ru/KIKIMR-14022
- Y_UNIT_TEST_TWIN(JoinSameKey, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(JoinSameKey) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -2817,8 +2814,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(JoinDictWithPure, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(JoinDictWithPure) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -2839,8 +2836,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(AsyncIndexUpdate, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(AsyncIndexUpdate) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -2865,8 +2862,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
UNIT_ASSERT_VALUES_EQUAL_C(result.GetStatus(), EStatus::SUCCESS, result.GetIssues().ToString());
}
- Y_UNIT_TEST_TWIN(DuplicatedResults, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(DuplicatedResults) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -2887,8 +2884,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
CompareYson(R"([[[3500u];["None"];[1u];["Anna"]];[[300u];["None"];[1u];["Paul"]];[[7200u];["None"];[2u];["Tony"]]])", FormatResultSetYson(result.GetResultSet(4)));
}
- Y_UNIT_TEST_TWIN(LookupColumns, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(LookupColumns) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -2913,8 +2910,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
}
}
- Y_UNIT_TEST_TWIN(OrderedScalarContext, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(OrderedScalarContext) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -2927,8 +2924,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
CompareYson(R"([[2u]])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(LiteralKeys, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(LiteralKeys) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -2971,8 +2968,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
UNIT_ASSERT_VALUES_EQUAL("/Root/Logs", stats.query_phases()[0].table_access()[0].name());
}
- Y_UNIT_TEST_TWIN(ReadDifferentColumns, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(ReadDifferentColumns) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -2991,8 +2988,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
UNIT_ASSERT_VALUES_EQUAL(reads[0]["columns"].GetArraySafe().size(), 3);
}
- Y_UNIT_TEST_TWIN(ReadDifferentColumnsPk, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(ReadDifferentColumnsPk) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -3015,8 +3012,8 @@ Y_UNIT_TEST_SUITE(KqpNewEngine) {
UNIT_ASSERT(readTypes.contains("Lookup"));
}
- Y_UNIT_TEST_TWIN(DependentSelect, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(DependentSelect) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
diff --git a/ydb/core/kqp/ut/kqp_olap_ut.cpp b/ydb/core/kqp/ut/kqp_olap_ut.cpp
index 408f1fad598..23379eef9aa 100644
--- a/ydb/core/kqp/ut/kqp_olap_ut.cpp
+++ b/ydb/core/kqp/ut/kqp_olap_ut.cpp
@@ -488,10 +488,9 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
}
}
- Y_UNIT_TEST_TWIN(SimpleQueryOlap, UseSessionActor) {
+ Y_UNIT_TEST(SimpleQueryOlap) {
auto settings = TKikimrSettings()
- .SetWithSampleTables(false)
- .SetEnableKqpSessionActor(UseSessionActor);
+ .SetWithSampleTables(false);
TKikimrRunner kikimr(settings);
// EnableDebugLogging(kikimr);
@@ -520,10 +519,9 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
}
}
- Y_UNIT_TEST_TWIN(SimpleLookupOlap, UseSessionActor) {
+ Y_UNIT_TEST(SimpleLookupOlap) {
auto settings = TKikimrSettings()
- .SetWithSampleTables(false)
- .SetEnableKqpSessionActor(UseSessionActor);
+ .SetWithSampleTables(false);
TKikimrRunner kikimr(settings);
// EnableDebugLogging(kikimr);
@@ -551,10 +549,9 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
}
}
- Y_UNIT_TEST_TWIN(SimpleRangeOlap, UseSessionActor) {
+ Y_UNIT_TEST(SimpleRangeOlap) {
auto settings = TKikimrSettings()
- .SetWithSampleTables(false)
- .SetEnableKqpSessionActor(UseSessionActor);
+ .SetWithSampleTables(false);
TKikimrRunner kikimr(settings);
// EnableDebugLogging(kikimr);
@@ -583,10 +580,9 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
}
}
- Y_UNIT_TEST_TWIN(CompositeRangeOlap, UseSessionActor) {
+ Y_UNIT_TEST(CompositeRangeOlap) {
auto settings = TKikimrSettings()
- .SetWithSampleTables(false)
- .SetEnableKqpSessionActor(UseSessionActor);
+ .SetWithSampleTables(false);
TKikimrRunner kikimr(settings);
// EnableDebugLogging(kikimr);
@@ -742,10 +738,9 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
session.Close();
}
- Y_UNIT_TEST_TWIN(QueryOltpAndOlap, UseSessionActor) {
+ Y_UNIT_TEST(QueryOltpAndOlap) {
auto settings = TKikimrSettings()
- .SetWithSampleTables(false)
- .SetEnableKqpSessionActor(UseSessionActor);
+ .SetWithSampleTables(false);
TKikimrRunner kikimr(settings);
// EnableDebugLogging(kikimr);
@@ -775,10 +770,9 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
}
}
- Y_UNIT_TEST_TWIN(EmptyRange, UseSessionActor) {
+ Y_UNIT_TEST(EmptyRange) {
auto settings = TKikimrSettings()
- .SetWithSampleTables(false)
- .SetEnableKqpSessionActor(UseSessionActor);
+ .SetWithSampleTables(false);
TKikimrRunner kikimr(settings);
TLocalHelper(kikimr).CreateTestOlapTable();
@@ -798,10 +792,9 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
CompareYson(StreamResultToYson(it), "[]");
}
- Y_UNIT_TEST_TWIN(Aggregation, UseSessionActor) {
+ Y_UNIT_TEST(Aggregation) {
auto settings = TKikimrSettings()
- .SetWithSampleTables(false)
- .SetEnableKqpSessionActor(UseSessionActor);
+ .SetWithSampleTables(false);
TKikimrRunner kikimr(settings);
// EnableDebugLogging(kikimr);
@@ -872,13 +865,12 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
}
}
- Y_UNIT_TEST_TWIN(PushdownFilter, UseSessionActor) {
+ Y_UNIT_TEST(PushdownFilter) {
static bool enableLog = false;
auto doTest = [](std::optional<bool> viaSettings, std::optional<bool> viaPragma, bool pushdownPresent) {
auto settings = TKikimrSettings()
- .SetWithSampleTables(false)
- .SetEnableKqpSessionActor(UseSessionActor);
+ .SetWithSampleTables(false);
if (enableLog) {
Cerr << "Run test:" << Endl;
@@ -971,10 +963,9 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
}
}
- Y_UNIT_TEST_TWIN(PKDescScan, UseSessionActor) {
+ Y_UNIT_TEST(PKDescScan) {
auto settings = TKikimrSettings()
- .SetWithSampleTables(false)
- .SetEnableKqpSessionActor(UseSessionActor);
+ .SetWithSampleTables(false);
TKikimrRunner kikimr(settings);
TStreamExecScanQuerySettings scanSettings;
@@ -1047,10 +1038,9 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
CompareYson(expectedYson, ysonResult);
}
- Y_UNIT_TEST_TWIN(ExtractRanges, UseSessionActor) {
+ Y_UNIT_TEST(ExtractRanges) {
auto settings = TKikimrSettings()
- .SetWithSampleTables(false)
- .SetEnableKqpSessionActor(UseSessionActor);
+ .SetWithSampleTables(false);
TKikimrRunner kikimr(settings);
TLocalHelper(kikimr).CreateTestOlapTable();
@@ -1079,10 +1069,9 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
UNIT_ASSERT(rows.size() == 6);
}
- Y_UNIT_TEST_TWIN(ExtractRangesReverse, UseSessionActor) {
+ Y_UNIT_TEST(ExtractRangesReverse) {
auto settings = TKikimrSettings()
- .SetWithSampleTables(false)
- .SetEnableKqpSessionActor(UseSessionActor);
+ .SetWithSampleTables(false);
TKikimrRunner kikimr(settings);
TLocalHelper(kikimr).CreateTestOlapTable();
@@ -1124,11 +1113,10 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
UNIT_ASSERT(rows.size() == expectedCount);
}
- Y_UNIT_TEST_TWIN(PredicatePushdown, UseSessionActor) {
+ Y_UNIT_TEST(PredicatePushdown) {
constexpr bool logQueries = false;
auto settings = TKikimrSettings()
- .SetWithSampleTables(false)
- .SetEnableKqpSessionActor(UseSessionActor);
+ .SetWithSampleTables(false);
TKikimrRunner kikimr(settings);
TStreamExecScanQuerySettings scanSettings;
@@ -1855,10 +1843,9 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
TestAggregations({ testCase });
}
- Y_UNIT_TEST_TWIN(StatsSysView, UseSessionActor) {
+ Y_UNIT_TEST(StatsSysView) {
auto settings = TKikimrSettings()
- .SetWithSampleTables(false)
- .SetEnableKqpSessionActor(UseSessionActor);
+ .SetWithSampleTables(false);
TKikimrRunner kikimr(settings);
static ui32 numKinds = 5;
@@ -1897,10 +1884,9 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
0.3*0.9*100*1000); // >= 90% of 100K inserted rows
}
- Y_UNIT_TEST_TWIN(StatsSysViewTable, UseSessionActor) {
+ Y_UNIT_TEST(StatsSysViewTable) {
auto settings = TKikimrSettings()
- .SetWithSampleTables(false)
- .SetEnableKqpSessionActor(UseSessionActor);
+ .SetWithSampleTables(false);
TKikimrRunner kikimr(settings);
static ui32 numKinds = 5;
@@ -2360,10 +2346,9 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
UNIT_ASSERT_VALUES_EQUAL(result, insertRows);
}
- Y_UNIT_TEST_TWIN(StatsSysViewColumns, UseSessionActor) {
+ Y_UNIT_TEST(StatsSysViewColumns) {
auto settings = TKikimrSettings()
- .SetWithSampleTables(false)
- .SetEnableKqpSessionActor(UseSessionActor);
+ .SetWithSampleTables(false);
TKikimrRunner kikimr(settings);
static ui32 numKinds = 5;
@@ -2421,10 +2406,9 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
}
}
- Y_UNIT_TEST_TWIN(StatsSysViewRanges, UseSessionActor) {
+ Y_UNIT_TEST(StatsSysViewRanges) {
auto settings = TKikimrSettings()
- .SetWithSampleTables(false)
- .SetEnableKqpSessionActor(UseSessionActor);
+ .SetWithSampleTables(false);
TKikimrRunner kikimr(settings);
static ui32 numKinds = 5;
@@ -2507,10 +2491,9 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
}
}
- Y_UNIT_TEST_TWIN(StatsSysViewFilter, UseSessionActor) {
+ Y_UNIT_TEST(StatsSysViewFilter) {
auto settings = TKikimrSettings()
- .SetWithSampleTables(false)
- .SetEnableKqpSessionActor(UseSessionActor);
+ .SetWithSampleTables(false);
TKikimrRunner kikimr(settings);
TLocalHelper(kikimr.GetTestServer()).CreateTestOlapTable();
@@ -2581,10 +2564,9 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
}
}
- Y_UNIT_TEST_TWIN(StatsSysViewAggregation, UseSessionActor) {
+ Y_UNIT_TEST(StatsSysViewAggregation) {
auto settings = TKikimrSettings()
- .SetWithSampleTables(false)
- .SetEnableKqpSessionActor(UseSessionActor);
+ .SetWithSampleTables(false);
TKikimrRunner kikimr(settings);
static ui32 numKinds = 5;
@@ -2758,11 +2740,10 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
}
}
- Y_UNIT_TEST_TWIN(PredicatePushdownWithParameters, UseSessionActor) {
+ Y_UNIT_TEST(PredicatePushdownWithParameters) {
constexpr bool logQueries = true;
auto settings = TKikimrSettings()
- .SetWithSampleTables(false)
- .SetEnableKqpSessionActor(UseSessionActor);
+ .SetWithSampleTables(false);
TKikimrRunner kikimr(settings);
TStreamExecScanQuerySettings scanSettings;
@@ -2843,10 +2824,9 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
UNIT_ASSERT(readRange.IsDefined());
}
- Y_UNIT_TEST_TWIN(PredicatePushdownParameterTypesValidation, UseSessionActor) {
+ Y_UNIT_TEST(PredicatePushdownParameterTypesValidation) {
auto settings = TKikimrSettings()
- .SetWithSampleTables(false)
- .SetEnableKqpSessionActor(UseSessionActor);
+ .SetWithSampleTables(false);
TKikimrRunner kikimr(settings);
TStreamExecScanQuerySettings scanSettings;
@@ -2900,10 +2880,9 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
}
}
- Y_UNIT_TEST_TWIN(PredicatePushdownCastErrors, UseSessionActor) {
+ Y_UNIT_TEST(PredicatePushdownCastErrors) {
auto settings = TKikimrSettings()
- .SetWithSampleTables(false)
- .SetEnableKqpSessionActor(UseSessionActor);
+ .SetWithSampleTables(false);
TKikimrRunner kikimr(settings);
TStreamExecScanQuerySettings scanSettings;
diff --git a/ydb/core/kqp/ut/kqp_params_ut.cpp b/ydb/core/kqp/ut/kqp_params_ut.cpp
index 5cd2e1ea861..8e41e15aafe 100644
--- a/ydb/core/kqp/ut/kqp_params_ut.cpp
+++ b/ydb/core/kqp/ut/kqp_params_ut.cpp
@@ -274,8 +274,8 @@ Y_UNIT_TEST_SUITE(KqpParams) {
UNIT_ASSERT_C(actual == expected1 || actual == expected2, "expected: " << expected1 << ", got: " << actual);
}
- Y_UNIT_TEST_TWIN(InvalidJson, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(InvalidJson) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
diff --git a/ydb/core/kqp/ut/kqp_query_ut.cpp b/ydb/core/kqp/ut/kqp_query_ut.cpp
index 589b1b515db..005ae38dc8e 100644
--- a/ydb/core/kqp/ut/kqp_query_ut.cpp
+++ b/ydb/core/kqp/ut/kqp_query_ut.cpp
@@ -86,7 +86,6 @@ Y_UNIT_TEST_SUITE(KqpQuery) {
Y_UNIT_TEST(QueryCacheTtl) {
NKikimrConfig::TAppConfig appConfig;
appConfig.MutableTableServiceConfig()->SetCompileQueryCacheTTLSec(2);
- appConfig.MutableTableServiceConfig()->SetEnableKqpSessionActor(true);
TKikimrRunner kikimr(appConfig);
auto db = kikimr.GetTableClient();
@@ -970,7 +969,6 @@ Y_UNIT_TEST_SUITE(KqpQuery) {
NKikimrConfig::TAppConfig appConfig;
appConfig.MutableTableServiceConfig()->MutableQueryLimits()->SetResultRowsLimit(6);
- appConfig.MutableTableServiceConfig()->SetEnableKqpSessionActor(true);
TKikimrRunner kikimr(appConfig, {setting});
auto db = kikimr.GetTableClient();
diff --git a/ydb/core/kqp/ut/kqp_scan_ut.cpp b/ydb/core/kqp/ut/kqp_scan_ut.cpp
index d060c153b52..029c9010d86 100644
--- a/ydb/core/kqp/ut/kqp_scan_ut.cpp
+++ b/ydb/core/kqp/ut/kqp_scan_ut.cpp
@@ -95,8 +95,8 @@ void CreateNullSampleTables(TKikimrRunner& kikimr) {
} // namespace
Y_UNIT_TEST_SUITE(KqpScan) {
- Y_UNIT_TEST_TWIN(IsNull, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(IsNull) {
+ auto kikimr = DefaultKikimrRunner();
CreateNullSampleTables(kikimr);
auto it = kikimr.GetTableClient().StreamExecuteScanQuery(R"(
@@ -108,8 +108,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
CompareYson(R"([[["One"]]])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(IsNullPartial, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(IsNullPartial) {
+ auto kikimr = DefaultKikimrRunner();
CreateNullSampleTables(kikimr);
auto it = kikimr.GetTableClient().StreamExecuteScanQuery(R"(
@@ -121,8 +121,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
CompareYson(R"([])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(NullInKey, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(NullInKey) {
+ auto kikimr = DefaultKikimrRunner();
CreateNullSampleTables(kikimr);
auto it = kikimr.GetTableClient().StreamExecuteScanQuery(R"(
@@ -135,8 +135,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
CompareYson(R"([[["Five"]];[["Four"]];[["Six"]]])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(NullInKeySuffix, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(NullInKeySuffix) {
+ auto kikimr = DefaultKikimrRunner();
CreateNullSampleTables(kikimr);
auto it = kikimr.GetTableClient().StreamExecuteScanQuery(R"(
@@ -151,9 +151,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(DecimalColumn, UseSessionActor) {
- //auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(DecimalColumn) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
TTableClient client{kikimr.GetDriver()};
auto session = client.CreateSession().GetValueSync().GetSession();
@@ -199,8 +198,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(Offset, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(Offset) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -215,8 +214,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(Limit, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(Limit) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -227,8 +226,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
CompareYson(R"([[[1u];["One"]];[[2u];["Two"]]])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(TopSort, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(TopSort) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -239,8 +238,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
CompareYson(R"([[[1u];["One"]]])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(Grep, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(Grep) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -260,8 +259,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
[[1];[802u];["Value2"]]])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(GrepByString, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(GrepByString) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -275,8 +274,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
[["ydb"];["ydb-1000"];["some very very very very long string"];[0]]])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(Order, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(Order) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto params = db.GetParamsBuilder()
@@ -302,8 +301,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(GrepRange, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(GrepRange) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto params = db.GetParamsBuilder()
@@ -332,8 +331,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(GrepLimit, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(GrepLimit) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto params = db.GetParamsBuilder()
@@ -370,8 +369,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(GrepNonKeyColumns, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(GrepNonKeyColumns) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
TParamsBuilder params;
@@ -404,8 +403,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(SingleKey, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(SingleKey) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto params = db.GetParamsBuilder()
@@ -427,8 +426,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(AggregateByColumn, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(AggregateByColumn) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -446,8 +445,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(AggregateNoColumn, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(AggregateNoColumn) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -461,8 +460,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
CompareYson(R"([[[36];[2.];18u;[3];[1];[19980u]]])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(AggregateNoColumnNoRemaps, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(AggregateNoColumnNoRemaps) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -476,8 +475,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
CompareYson(R"([[[36];[2.];18u]])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(AggregateWithFunction, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(AggregateWithFunction) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -490,8 +489,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
CompareYson(R"([[[436]]])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(AggregateCountStar, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(AggregateCountStar) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery("SELECT COUNT(*) FROM `/Root/EightShard`").GetValueSync();
@@ -499,8 +498,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
CompareYson(R"([[24u]])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(AggregateEmptyCountStar, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(AggregateEmptyCountStar) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery("SELECT COUNT(*) FROM `/Root/EightShard` WHERE Key < 10").GetValueSync();
@@ -508,8 +507,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
CompareYson(R"([[0u]])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(AggregateEmptySum, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(AggregateEmptySum) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery("SELECT SUM(Data) FROM `/Root/EightShard` WHERE Key < 10").GetValueSync();
@@ -517,8 +516,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
CompareYson(R"([[#]])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(JoinSimple, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(JoinSimple) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
CreateSampleTables(kikimr);
@@ -540,8 +539,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(Join, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(Join) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
CreateSampleTables(kikimr);
@@ -568,8 +567,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
test(false);
}
- Y_UNIT_TEST_TWIN(Join2, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(Join2) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
CreateSampleTables(kikimr);
@@ -591,8 +590,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(Join3, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(Join3) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
CreateSampleTables(kikimr);
@@ -625,8 +624,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
test(false);
}
- Y_UNIT_TEST_TWIN(Join4, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(Join4) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
CreateSampleTables(kikimr);
@@ -667,8 +666,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(LeftSemiJoinSimple, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(LeftSemiJoinSimple) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
CreateSampleTables(kikimr);
@@ -689,8 +688,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
[[302u];["Value-302"];["302"]]])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(RightJoinSimple, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(RightJoinSimple) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
CreateSampleTables(kikimr);
@@ -711,8 +710,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
)", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(RightOnlyJoinSimple, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(RightOnlyJoinSimple) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
CreateSampleTables(kikimr);
@@ -731,8 +730,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(RightSemiJoinSimple, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(RightSemiJoinSimple) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
CreateSampleTables(kikimr);
@@ -751,8 +750,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
)", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(JoinWithParams, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(JoinWithParams) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto params = TParamsBuilder().AddParam("$in")
.BeginList()
@@ -778,8 +777,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
}
}
- Y_UNIT_TEST_TWIN(NoTruncate, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(NoTruncate) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -851,8 +850,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
UNIT_ASSERT_VALUES_EQUAL(totalRows, RowsCount);
}
- Y_UNIT_TEST_TWIN(Join3TablesNoRemap, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(Join3TablesNoRemap) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
CreateSampleTables(kikimr);
@@ -880,8 +879,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(Join3Tables, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(Join3Tables) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
CreateSampleTables(kikimr);
@@ -912,8 +911,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
test(false /* DisableSimpleColumns */);
}
- Y_UNIT_TEST_TWIN(JoinLeftOnly, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(JoinLeftOnly) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
CreateSampleTables(kikimr);
@@ -945,8 +944,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
test(false /* DisableSimpleColumns */);
}
- Y_UNIT_TEST_TWIN(CrossJoin, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(CrossJoin) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
CreateSampleTables(kikimr);
@@ -988,8 +987,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(SelfJoin3xSameLabels, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(SelfJoin3xSameLabels) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
CreateSampleTables(kikimr);
@@ -1014,8 +1013,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
CompareYson("[[[1u]];[[2u]]]", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(SelfJoin3x, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(SelfJoin3x) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
CreateSampleTables(kikimr);
@@ -1041,8 +1040,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
}
#if 0
- Y_UNIT_TEST_TWIN(JoinParams, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(JoinParams) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto params = TParamsBuilder().AddParam("$in").BeginList()
@@ -1063,8 +1062,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
Cerr << StreamResultToYson(it) << Endl;
}
- Y_UNIT_TEST_TWIN(JoinParams2, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(JoinParams2) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto params = TParamsBuilder()
@@ -1093,8 +1092,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
Cerr << StreamResultToYson(it) << Endl;
}
- Y_UNIT_TEST_TWIN(JoinParams3, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(JoinParams3) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto params = TParamsBuilder()
@@ -1127,10 +1126,10 @@ Y_UNIT_TEST_SUITE(KqpScan) {
}
#endif
- Y_UNIT_TEST_QUAD(PrunePartitionsByLiteral, WithPredicatesExtract, UseSessionActor) {
+ Y_UNIT_TEST_TWIN(PrunePartitionsByLiteral, WithPredicatesExtract) {
auto cfg = AppCfg();
cfg.MutableFeatureFlags()->SetEnablePredicateExtractForScanQueries(WithPredicatesExtract);
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, cfg);
+ auto kikimr = DefaultKikimrRunner({}, cfg);
auto db = kikimr.GetTableClient();
TStreamExecScanQuerySettings settings;
@@ -1176,8 +1175,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
}
}
- Y_UNIT_TEST_TWIN(PrunePartitionsByExpr, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(PrunePartitionsByExpr) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
TStreamExecScanQuerySettings settings;
@@ -1205,14 +1204,14 @@ Y_UNIT_TEST_SUITE(KqpScan) {
UNIT_ASSERT_VALUES_EQUAL(res.QueryStats->query_phases(1).affected_shards(), 1);
}
- Y_UNIT_TEST_TWIN(TooManyComputeActors, UseSessionActor) {
+ Y_UNIT_TEST(TooManyComputeActors) {
TVector<NKikimrKqp::TKqpSetting> settings;
auto setting = NKikimrKqp::TKqpSetting();
setting.SetName("_KqpMaxComputeActors");
setting.SetValue("5");
settings.push_back(setting);
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, settings);
+ auto kikimr = DefaultKikimrRunner(settings);
auto db = kikimr.GetTableClient();
CreateSampleTables(kikimr);
@@ -1244,7 +1243,7 @@ Y_UNIT_TEST_SUITE(KqpScan) {
UNIT_ASSERT_EQUAL(part.GetStatus(), EStatus::CLIENT_OUT_OF_RANGE);
}
- Y_UNIT_TEST_TWIN(EarlyFinish, UseSessionActor) {
+ Y_UNIT_TEST(EarlyFinish) {
auto appCfg = AppCfg();
appCfg.MutableTableServiceConfig()->MutableResourceManager()->SetChannelBufferSize(5);
appCfg.MutableTableServiceConfig()->MutableResourceManager()->SetMinChannelBufferSize(5);
@@ -1254,7 +1253,7 @@ Y_UNIT_TEST_SUITE(KqpScan) {
NYql::NDq::GetDqExecutionSettingsForTests().Reset();
};
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, appCfg);
+ auto kikimr = DefaultKikimrRunner({}, appCfg);
NYdb::NTable::TTableClient client(kikimr.GetDriver());
auto session = client.CreateSession().GetValueSync().GetSession();
@@ -1282,8 +1281,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
UNIT_ASSERT_C(it.IsSuccess(), it.GetIssues().ToString());
}
- Y_UNIT_TEST_TWIN(MultipleResults, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(MultipleResults) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -1297,8 +1296,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
UNIT_ASSERT_EQUAL_C(part.GetStatus(), EStatus::PRECONDITION_FAILED, part.GetIssues().ToString());
}
- Y_UNIT_TEST_TWIN(Effects, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(Effects) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -1314,8 +1313,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
UNIT_ASSERT_EQUAL_C(part.GetStatus(), EStatus::PRECONDITION_FAILED, part.GetIssues().ToString());
}
- Y_UNIT_TEST_TWIN(PureExpr, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(PureExpr) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -1326,8 +1325,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
CompareYson(R"([["42";42;25]])", res);
}
- Y_UNIT_TEST_TWIN(UnionWithPureExpr, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(UnionWithPureExpr) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -1340,8 +1339,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
CompareYson(R"([["42";[42];[25]];["forty-two";#;#]])", res);
}
- Y_UNIT_TEST_TWIN(MiltiExprWithPure, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(MiltiExprWithPure) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -1354,8 +1353,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
UNIT_ASSERT_EQUAL_C(part.GetStatus(), EStatus::PRECONDITION_FAILED, part.GetIssues().ToString());
}
- Y_UNIT_TEST_TWIN(UnionBasic, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(UnionBasic) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -1368,8 +1367,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
CompareYson(R"([[[1u]];[[101u]]])", res);
}
- Y_UNIT_TEST_TWIN(UnionMixed, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(UnionMixed) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -1382,8 +1381,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
CompareYson(R"([[[42];#];[#;[101u]]])", res);
}
- Y_UNIT_TEST_TWIN(UnionThree, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(UnionThree) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -1398,8 +1397,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
CompareYson(R"([[[1u]];[[101u]];[[4000000003u]]])", res);
}
- Y_UNIT_TEST_TWIN(UnionSameTable, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(UnionSameTable) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -1412,8 +1411,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
CompareYson(R"([[[1u]];[[1u]]])", res);
}
- Y_UNIT_TEST_TWIN(UnionAggregate, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(UnionAggregate) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -1428,8 +1427,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
CompareYson(R"([[[2u]];[[24u]];[[11000u]]])", res);
}
- Y_UNIT_TEST_TWIN(CountDistinct, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(CountDistinct) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -1441,8 +1440,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
CompareYson(R"([[1u;1u];[1u;1u]])", res);
}
- Y_UNIT_TEST_TWIN(FullFrameWindow, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(FullFrameWindow) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -1456,8 +1455,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
CompareYson(R"([[[15];8u];[[16];8u];[[17];8u]])", res);
}
- Y_UNIT_TEST_TWIN(SimpleWindow, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(SimpleWindow) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -1483,8 +1482,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
])", res);
}
- Y_UNIT_TEST_TWIN(TwoAggregatesOneFullFrameWindow, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(TwoAggregatesOneFullFrameWindow) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -1500,8 +1499,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
CompareYson(R"([[[17];[2.125];8u]])", res);
}
- Y_UNIT_TEST_TWIN(TwoAggregatesTwoWindows, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(TwoAggregatesTwoWindows) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -1526,8 +1525,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
])", res);
}
- Y_UNIT_TEST_TWIN(CustomWindow, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(CustomWindow) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -1552,8 +1551,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
])", res);
}
- Y_UNIT_TEST_TWIN(EmptySet, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(EmptySet) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -1564,8 +1563,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
CompareYson("[]",res);
}
- Y_UNIT_TEST_TWIN(RestrictSqlV0, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(RestrictSqlV0) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -1579,8 +1578,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
UNIT_ASSERT_EQUAL_C(part.GetStatus(), EStatus::GENERIC_ERROR, part.GetStatus());
}
- Y_UNIT_TEST_TWIN(LongStringCombiner, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(LongStringCombiner) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -1591,8 +1590,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
CompareYson(R"([[[" GET /index.html HTTP/1.1"];["some very very very very long string"]]])",res);
}
- Y_UNIT_TEST_TWIN(SqlInParameter, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(SqlInParameter) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto result = db.CreateSession().GetValueSync().GetSession().ExecuteDataQuery(R"(
@@ -1625,8 +1624,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
[[3u];["Three"]]])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(SqlInLiteral, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(SqlInLiteral) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto result = db.CreateSession().GetValueSync().GetSession().ExecuteDataQuery(R"(
@@ -1650,7 +1649,7 @@ Y_UNIT_TEST_SUITE(KqpScan) {
[[3u];["Three"]]])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(UdfFailure, UseSessionActor) {
+ Y_UNIT_TEST(UdfFailure) {
auto testFn = [](bool disableLlvmForUdfStages) {
TVector<NKikimrKqp::TKqpSetting> settings;
auto setting = NKikimrKqp::TKqpSetting();
@@ -1658,7 +1657,7 @@ Y_UNIT_TEST_SUITE(KqpScan) {
setting.SetValue(disableLlvmForUdfStages ? "true" : "false");
settings.push_back(setting);
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, settings);
+ auto kikimr = DefaultKikimrRunner(settings);
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -1682,8 +1681,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
testFn(true);
}
- Y_UNIT_TEST_TWIN(SecondaryIndex, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(SecondaryIndex) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -1741,8 +1740,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
}
}
- Y_UNIT_TEST_TWIN(BoolFlag, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(BoolFlag) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
TTableClient client{kikimr.GetDriver()};
auto session = client.CreateSession().GetValueSync().GetSession();
@@ -1776,8 +1775,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
])", StreamResultToYson(it));
}
- Y_UNIT_TEST_TWIN(Counters, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(Counters) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto it = db.StreamExecuteScanQuery(R"(
@@ -1790,8 +1789,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
UNIT_ASSERT_VALUES_EQUAL(1, counters.GetQueryTypeCounter(NKikimrKqp::EQueryType::QUERY_TYPE_SQL_SCAN)->Val());
}
- Y_UNIT_TEST_TWIN(DropRedundantSortByPk, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, AppCfg());
+ Y_UNIT_TEST(DropRedundantSortByPk) {
+ auto kikimr = DefaultKikimrRunner({}, AppCfg());
auto db = kikimr.GetTableClient();
auto settings = TStreamExecScanQuerySettings()
@@ -1833,10 +1832,9 @@ Y_UNIT_TEST_SUITE(KqpScan) {
}
}
- Y_UNIT_TEST_TWIN(LMapFunction, UseSessionActor) {
+ Y_UNIT_TEST(LMapFunction) {
auto settings = TKikimrSettings()
- .SetWithSampleTables(false)
- .SetEnableKqpSessionActor(UseSessionActor);
+ .SetWithSampleTables(false);
TKikimrRunner kikimr(settings);
auto tableClient = kikimr.GetTableClient();
@@ -1879,12 +1877,12 @@ Y_UNIT_TEST_SUITE(KqpScan) {
CompareYson(result, R"([[[2];[1000];["Dogecoin"]];[[4];[1];["XTC"]];[[5];[2];["Cardano"]];[[6];[3];["Tether"]]])");
}
- Y_UNIT_TEST_TWIN(YqlTableSample, UseSessionActor) {
+ Y_UNIT_TEST(YqlTableSample) {
auto setting = NKikimrKqp::TKqpSetting();
setting.SetName("_KqpYqlSyntaxVersion");
setting.SetValue("1");
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {setting});
+ auto kikimr = DefaultKikimrRunner({setting});
auto db = kikimr.GetTableClient();
const TString query(R"(SELECT * FROM `/Root/Test` TABLESAMPLE SYSTEM(1.0);)");
@@ -1898,8 +1896,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
}));
}
- Y_UNIT_TEST_TWIN(CrossJoinOneColumn, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(CrossJoinOneColumn) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
CreateSampleTables(kikimr);
@@ -1924,8 +1922,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
CompareYson(R"([[24u]])", StreamResultToYson(result));
}
- Y_UNIT_TEST_TWIN(CrossJoinCount, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(CrossJoinCount) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
CreateSampleTables(kikimr);
@@ -1939,8 +1937,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
CompareYson(R"([[192u]])", StreamResultToYson(result));
}
- Y_UNIT_TEST_TWIN(SelectExistsUnexpected, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(SelectExistsUnexpected) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
CreateSampleTables(kikimr);
@@ -1964,8 +1962,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
CompareYson("[[%false]]", StreamResultToYson(result));
}
- Y_UNIT_TEST_TWIN(StreamLookup, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(StreamLookup) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
CreateSampleTables(kikimr);
@@ -1992,8 +1990,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
}
}
- Y_UNIT_TEST_TWIN(StreamLookupByPkPrefix, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(StreamLookupByPkPrefix) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
CreateSampleTables(kikimr);
@@ -2035,7 +2033,7 @@ Y_UNIT_TEST_SUITE(KqpScan) {
}
}
- Y_UNIT_TEST_TWIN(StreamLookupTryGetDataBeforeSchemeInitialization, UseSessionActor) {
+ Y_UNIT_TEST(StreamLookupTryGetDataBeforeSchemeInitialization) {
TPortManager tp;
ui16 mbusport = tp.GetPort(2134);
@@ -2131,8 +2129,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
)");
}
- Y_UNIT_TEST_TWIN(LimitOverSecondaryIndexRead, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(LimitOverSecondaryIndexRead) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -2166,8 +2164,8 @@ Y_UNIT_TEST_SUITE(KqpScan) {
UNIT_ASSERT(limit.IsDefined());
}
- Y_UNIT_TEST_TWIN(TopSortOverSecondaryIndexRead, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(TopSortOverSecondaryIndexRead) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
diff --git a/ydb/core/kqp/ut/kqp_service_ut.cpp b/ydb/core/kqp/ut/kqp_service_ut.cpp
index ce77ad2a461..9162720a785 100644
--- a/ydb/core/kqp/ut/kqp_service_ut.cpp
+++ b/ydb/core/kqp/ut/kqp_service_ut.cpp
@@ -9,13 +9,11 @@ using namespace NYdb;
using namespace NYdb::NTable;
Y_UNIT_TEST_SUITE(KqpService) {
- Y_UNIT_TEST_TWIN(Shutdown, UseSessionActor) {
+ Y_UNIT_TEST(Shutdown) {
const ui32 Inflight = 50;
const TDuration WaitDuration = TDuration::Seconds(1);
- auto settings = TKikimrSettings()
- .SetEnableKqpSessionActor(UseSessionActor);
- auto kikimr = MakeHolder<TKikimrRunner>(settings);
+ auto kikimr = MakeHolder<TKikimrRunner>();
NPar::LocalExecutor().RunAdditionalThreads(Inflight);
auto driverConfig = kikimr->GetDriverConfig();
@@ -66,10 +64,8 @@ Y_UNIT_TEST_SUITE(KqpService) {
driver.Stop(true);
}
- Y_UNIT_TEST_TWIN(CloseSessionsWithLoad, UseSessionActor) {
- auto settings = TKikimrSettings()
- .SetEnableKqpSessionActor(UseSessionActor);
- auto kikimr = std::make_shared<TKikimrRunner>(settings);
+ Y_UNIT_TEST(CloseSessionsWithLoad) {
+ auto kikimr = std::make_shared<TKikimrRunner>();
auto db = kikimr->GetTableClient();
const ui32 SessionsCount = 50;
@@ -144,11 +140,11 @@ Y_UNIT_TEST_SUITE(KqpService) {
return futures;
}
- Y_UNIT_TEST_TWIN(SessionBusy, UseSessionActor) {
+ Y_UNIT_TEST(SessionBusy) {
NKikimrConfig::TAppConfig appConfig;
appConfig.MutableTableServiceConfig()->SetUseSessionBusyStatus(true);
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, appConfig);
+ auto kikimr = DefaultKikimrRunner({}, appConfig);
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -164,11 +160,11 @@ Y_UNIT_TEST_SUITE(KqpService) {
}
}
- Y_UNIT_TEST_TWIN(SessionBusyRetryOperation, UseSessionActor) {
+ Y_UNIT_TEST(SessionBusyRetryOperation) {
NKikimrConfig::TAppConfig appConfig;
appConfig.MutableTableServiceConfig()->SetUseSessionBusyStatus(true);
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, appConfig);
+ auto kikimr = DefaultKikimrRunner({}, appConfig);
auto db = kikimr.GetTableClient();
ui32 queriesCount = 10;
@@ -196,11 +192,11 @@ Y_UNIT_TEST_SUITE(KqpService) {
UNIT_ASSERT_VALUES_EQUAL_C(status.GetStatus(), EStatus::SUCCESS, status.GetIssues().ToString());
}
- Y_UNIT_TEST_TWIN(SessionBusyRetryOperationSync, UseSessionActor) {
+ Y_UNIT_TEST(SessionBusyRetryOperationSync) {
NKikimrConfig::TAppConfig appConfig;
appConfig.MutableTableServiceConfig()->SetUseSessionBusyStatus(true);
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {}, appConfig);
+ auto kikimr = DefaultKikimrRunner({}, appConfig);
auto db = kikimr.GetTableClient();
ui32 queriesCount = 10;
diff --git a/ydb/core/kqp/ut/kqp_stats_ut.cpp b/ydb/core/kqp/ut/kqp_stats_ut.cpp
index 9c9eb0f4a1a..7c97c8c5d2c 100644
--- a/ydb/core/kqp/ut/kqp_stats_ut.cpp
+++ b/ydb/core/kqp/ut/kqp_stats_ut.cpp
@@ -14,8 +14,8 @@ using namespace NYdb::NTable;
Y_UNIT_TEST_SUITE(KqpStats) {
-Y_UNIT_TEST_TWIN(MultiTxStatsFullExp, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+Y_UNIT_TEST(MultiTxStatsFullExp) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
TStreamExecScanQuerySettings settings;
@@ -39,8 +39,8 @@ Y_UNIT_TEST_TWIN(MultiTxStatsFullExp, UseSessionActor) {
UNIT_ASSERT_EQUAL(node.GetMap().at("Stats").GetMapSafe().at("TotalTasks").GetIntegerSafe(), 2);
}
-Y_UNIT_TEST_TWIN(JoinNoStats, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+Y_UNIT_TEST(JoinNoStats) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
TStreamExecScanQuerySettings settings;
settings.CollectQueryStats(ECollectQueryStatsMode::None);
@@ -57,9 +57,8 @@ Y_UNIT_TEST_TWIN(JoinNoStats, UseSessionActor) {
UNIT_ASSERT(!res.PlanJson);
}
-Y_UNIT_TEST_TWIN(JoinStatsBasic, UseSessionActor) {
+Y_UNIT_TEST(JoinStatsBasic) {
auto settings = TKikimrSettings()
- .SetEnableKqpSessionActor(UseSessionActor)
.SetEnableKqpScanQueryStreamLookup(false); // TODO: enable stream lookup KIKIMR-14294
TKikimrRunner kikimr(settings);
@@ -93,8 +92,8 @@ Y_UNIT_TEST_TWIN(JoinStatsBasic, UseSessionActor) {
UNIT_ASSERT(!res.PlanJson);
}
-Y_UNIT_TEST_TWIN(MultiTxStatsFull, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+Y_UNIT_TEST(MultiTxStatsFull) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
TStreamExecScanQuerySettings settings;
settings.CollectQueryStats(ECollectQueryStatsMode::Full);
@@ -122,8 +121,8 @@ Y_UNIT_TEST_TWIN(MultiTxStatsFull, UseSessionActor) {
UNIT_ASSERT_EQUAL(node.GetMap().at("Stats").GetMapSafe().at("TotalTasks").GetIntegerSafe(), 2);
}
-Y_UNIT_TEST_TWIN(DeferredEffects, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+Y_UNIT_TEST(DeferredEffects) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
TString planJson;
@@ -186,8 +185,8 @@ Y_UNIT_TEST_TWIN(DeferredEffects, UseSessionActor) {
UNIT_ASSERT(std::atoi(ru->second.c_str()) > 1);
}
-Y_UNIT_TEST_TWIN(DataQueryWithEffects, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+Y_UNIT_TEST(DataQueryWithEffects) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -210,7 +209,7 @@ Y_UNIT_TEST_TWIN(DataQueryWithEffects, UseSessionActor) {
}
Y_UNIT_TEST(DataQueryOldEngine) {
- auto kikimr = KikimrRunnerEnableSessionActor(false);
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -226,8 +225,8 @@ Y_UNIT_TEST(DataQueryOldEngine) {
AssertSuccessResult(result);
}
-Y_UNIT_TEST_TWIN(DataQueryMulti, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+Y_UNIT_TEST(DataQueryMulti) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -249,8 +248,8 @@ Y_UNIT_TEST_TWIN(DataQueryMulti, UseSessionActor) {
UNIT_ASSERT_EQUAL_C(plan.GetMapSafe().at("Plan").GetMapSafe().at("Plans").GetArraySafe().size(), 0, result.GetQueryPlan());
}
-Y_UNIT_TEST_TWIN(RequestUnitForBadRequestExecute, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+Y_UNIT_TEST(RequestUnitForBadRequestExecute) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -267,8 +266,8 @@ Y_UNIT_TEST_TWIN(RequestUnitForBadRequestExecute, UseSessionActor) {
UNIT_ASSERT(result.GetConsumedRu() > 0);
}
-Y_UNIT_TEST_TWIN(RequestUnitForBadRequestExplicitPrepare, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+Y_UNIT_TEST(RequestUnitForBadRequestExplicitPrepare) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -284,8 +283,8 @@ Y_UNIT_TEST_TWIN(RequestUnitForBadRequestExplicitPrepare, UseSessionActor) {
UNIT_ASSERT(result.GetConsumedRu() > 0);
}
-Y_UNIT_TEST_TWIN(RequestUnitForSuccessExplicitPrepare, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+Y_UNIT_TEST(RequestUnitForSuccessExplicitPrepare) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -302,8 +301,8 @@ Y_UNIT_TEST_TWIN(RequestUnitForSuccessExplicitPrepare, UseSessionActor) {
UNIT_ASSERT(result.GetConsumedRu() > 1);
}
-Y_UNIT_TEST_TWIN(RequestUnitForExecute, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+Y_UNIT_TEST(RequestUnitForExecute) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -329,8 +328,8 @@ Y_UNIT_TEST_TWIN(RequestUnitForExecute, UseSessionActor) {
}
}
-Y_UNIT_TEST_TWIN(StatsProfile, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+Y_UNIT_TEST(StatsProfile) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
diff --git a/ydb/core/kqp/ut/kqp_sys_view_ut.cpp b/ydb/core/kqp/ut/kqp_sys_view_ut.cpp
index 825233605a2..17d421c0608 100644
--- a/ydb/core/kqp/ut/kqp_sys_view_ut.cpp
+++ b/ydb/core/kqp/ut/kqp_sys_view_ut.cpp
@@ -380,9 +380,9 @@ Y_UNIT_TEST_SUITE(KqpSystemView) {
checkTable("`/Root/.sys/top_queries_by_cpu_time_one_hour`");
}
- Y_UNIT_TEST_TWIN(QueryStatsScan, UseSessionActor) {
+ Y_UNIT_TEST(QueryStatsScan) {
auto checkTable = [&] (const TStringBuf tableName) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ auto kikimr = DefaultKikimrRunner();
auto client = kikimr.GetTableClient();
{
diff --git a/ydb/core/kqp/ut/kqp_tx_ut.cpp b/ydb/core/kqp/ut/kqp_tx_ut.cpp
index 4282ea80226..44dcd900849 100644
--- a/ydb/core/kqp/ut/kqp_tx_ut.cpp
+++ b/ydb/core/kqp/ut/kqp_tx_ut.cpp
@@ -10,7 +10,7 @@ using namespace NYdb::NTable;
Y_UNIT_TEST_SUITE(KqpTx) {
Y_UNIT_TEST(DeferredEffects) {
- auto kikimr = KikimrRunnerEnableSessionActor(true);
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -47,7 +47,7 @@ Y_UNIT_TEST_SUITE(KqpTx) {
}
Y_UNIT_TEST(ExplicitTcl) {
- auto kikimr = KikimrRunnerEnableSessionActor(true);
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -81,8 +81,8 @@ Y_UNIT_TEST_SUITE(KqpTx) {
UNIT_ASSERT(HasIssue(commitResult.GetIssues(), NYql::TIssuesIds::KIKIMR_TRANSACTION_NOT_FOUND));
}
- Y_UNIT_TEST_TWIN(LocksAbortOnCommit, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(LocksAbortOnCommit) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
{
@@ -119,7 +119,7 @@ Y_UNIT_TEST_SUITE(KqpTx) {
}
Y_UNIT_TEST(InteractiveTx) {
- auto kikimr = KikimrRunnerEnableSessionActor(true);
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -155,7 +155,7 @@ Y_UNIT_TEST_SUITE(KqpTx) {
}
Y_UNIT_TEST(BeginTransactionBadMode) {
- auto kikimr = KikimrRunnerEnableSessionActor(true);
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -167,7 +167,7 @@ Y_UNIT_TEST_SUITE(KqpTx) {
}
Y_UNIT_TEST(CommitRequired) {
- auto kikimr = KikimrRunnerEnableSessionActor(true);
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -183,7 +183,7 @@ Y_UNIT_TEST_SUITE(KqpTx) {
}
Y_UNIT_TEST(RollbackTx) {
- auto kikimr = KikimrRunnerEnableSessionActor(true);
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -212,7 +212,7 @@ Y_UNIT_TEST_SUITE(KqpTx) {
}
Y_UNIT_TEST(RollbackTx2) {
- auto kikimr = KikimrRunnerEnableSessionActor(true);
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -240,12 +240,12 @@ Y_UNIT_TEST_SUITE(KqpTx) {
UNIT_ASSERT(HasIssue(rollbackResult.GetIssues(), NYql::TIssuesIds::KIKIMR_TRANSACTION_NOT_FOUND));
}
- Y_UNIT_TEST_TWIN(RollbackManyTx, UseSessionActor) {
+ Y_UNIT_TEST(RollbackManyTx) {
auto setting = NKikimrKqp::TKqpSetting();
setting.SetName("_KqpMaxActiveTxPerSession");
setting.SetValue("10");
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {setting});
+ auto kikimr = DefaultKikimrRunner({setting});
auto db = kikimr.GetTableClient();
auto query = R"(
@@ -293,7 +293,7 @@ Y_UNIT_TEST_SUITE(KqpTx) {
}
Y_UNIT_TEST(RollbackRoTx) {
- auto kikimr = KikimrRunnerEnableSessionActor(true);
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -315,7 +315,7 @@ Y_UNIT_TEST_SUITE(KqpTx) {
}
Y_UNIT_TEST(CommitRoTx) {
- auto kikimr = KikimrRunnerEnableSessionActor(true);
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -333,7 +333,7 @@ Y_UNIT_TEST_SUITE(KqpTx) {
}
Y_UNIT_TEST(CommitRoTx_TLI) {
- auto kikimr = KikimrRunnerEnableSessionActor(true);
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -363,7 +363,7 @@ Y_UNIT_TEST_SUITE(KqpTx) {
}
Y_UNIT_TEST(EmptyTxOnCommit) {
- auto kikimr = KikimrRunnerEnableSessionActor(true);
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -382,7 +382,7 @@ Y_UNIT_TEST_SUITE(KqpTx) {
setting.SetName("_KqpMaxActiveTxPerSession");
setting.SetValue("2");
- auto kikimr = KikimrRunnerEnableSessionActor(true, {setting});
+ auto kikimr = DefaultKikimrRunner({setting});
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -411,7 +411,7 @@ Y_UNIT_TEST_SUITE(KqpTx) {
setting.SetValue("0");
settings.push_back(setting);
- auto kikimr = KikimrRunnerEnableSessionActor(true, settings);
+ auto kikimr = DefaultKikimrRunner(settings);
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -435,7 +435,7 @@ Y_UNIT_TEST_SUITE(KqpTx) {
}
Y_UNIT_TEST(RollbackInvalidated) {
- auto kikimr = KikimrRunnerEnableSessionActor(true);
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -460,7 +460,7 @@ Y_UNIT_TEST_SUITE(KqpTx) {
}
Y_UNIT_TEST(CommitPrepared) {
- auto kikimr = KikimrRunnerEnableSessionActor(true);
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -482,7 +482,7 @@ Y_UNIT_TEST_SUITE(KqpTx) {
}
Y_UNIT_TEST(InvalidateOnError) {
- auto kikimr = KikimrRunnerEnableSessionActor(true);
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -505,7 +505,7 @@ Y_UNIT_TEST_SUITE(KqpTx) {
}
Y_UNIT_TEST(CommitStats) {
- auto kikimr = KikimrRunnerEnableSessionActor(true);
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -533,9 +533,8 @@ Y_UNIT_TEST_SUITE(KqpTx) {
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases(0).table_access(0).updates().rows(), 1);
}
- Y_UNIT_TEST_TWIN(MixEnginesOldNew, UseSessionActor) {
- //TKikimrRunner kikimr;
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(MixEnginesOldNew) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -564,8 +563,8 @@ Y_UNIT_TEST_SUITE(KqpTx) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(SnapshotRO, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(SnapshotRO) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -594,8 +593,8 @@ Y_UNIT_TEST_SUITE(KqpTx) {
UNIT_ASSERT(HasIssue(result.GetIssues(), NYql::TIssuesIds::KIKIMR_BAD_OPERATION));
}
- Y_UNIT_TEST_TWIN(SnapshotROInteractive1, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(SnapshotROInteractive1) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -628,8 +627,8 @@ Y_UNIT_TEST_SUITE(KqpTx) {
CompareYson(readResult, FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(SnapshotROInteractive2, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(SnapshotROInteractive2) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -666,7 +665,7 @@ Y_UNIT_TEST_SUITE(KqpTx) {
UNIT_ASSERT_VALUES_EQUAL_C(commitResult.GetStatus(), EStatus::SUCCESS, commitResult.GetIssues().ToString());
}
- Y_UNIT_TEST_TWIN(SnapshotRONoMvccReads, UseSessionActor) {
+ Y_UNIT_TEST(SnapshotRONoMvccReads) {
TKikimrRunner kikimr(TKikimrSettings()
.SetEnableMvccSnapshotReads(false));
diff --git a/ydb/core/kqp/ut/kqp_types_arrow_ut.cpp b/ydb/core/kqp/ut/kqp_types_arrow_ut.cpp
index 96e9a0bbfca..443655e3c3b 100644
--- a/ydb/core/kqp/ut/kqp_types_arrow_ut.cpp
+++ b/ydb/core/kqp/ut/kqp_types_arrow_ut.cpp
@@ -12,8 +12,7 @@ namespace {
TKikimrRunner RunnerWithArrowFormatEnabled() {
auto settings = TKikimrSettings()
- .SetEnableArrowFormatAtDatashard(true)
- .SetEnableKqpSessionActor(true);
+ .SetEnableArrowFormatAtDatashard(true);
return TKikimrRunner{settings};
}
diff --git a/ydb/core/kqp/ut/kqp_write_ut.cpp b/ydb/core/kqp/ut/kqp_write_ut.cpp
index 40e2baf4dac..4d4f0e0700f 100644
--- a/ydb/core/kqp/ut/kqp_write_ut.cpp
+++ b/ydb/core/kqp/ut/kqp_write_ut.cpp
@@ -9,12 +9,12 @@ using namespace NYdb;
using namespace NYdb::NTable;
Y_UNIT_TEST_SUITE(KqpWrite) {
- Y_UNIT_TEST_TWIN(UpsertNullKey, UseSessionActor) {
+ Y_UNIT_TEST(UpsertNullKey) {
auto setting = NKikimrKqp::TKqpSetting();
setting.SetName("_KqpYqlSyntaxVersion");
setting.SetValue("1");
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor, {setting});
+ auto kikimr = DefaultKikimrRunner({setting});
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -85,8 +85,8 @@ Y_UNIT_TEST_SUITE(KqpWrite) {
}
}
- Y_UNIT_TEST_TWIN(Insert, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(Insert) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -202,8 +202,8 @@ Y_UNIT_TEST_SUITE(KqpWrite) {
CompareYson(R"([[[3u]]])", FormatResultSetYson(result.GetResultSet(1)));
}
- Y_UNIT_TEST_TWIN(InsertRevert, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(InsertRevert) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -323,8 +323,8 @@ Y_UNIT_TEST_SUITE(KqpWrite) {
CompareYson(R"([[[1u]];[[2u]];[[3u]]])", FormatResultSetYson(result.GetResultSet(1)));
}
- Y_UNIT_TEST_TWIN(ProjectReplace, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(ProjectReplace) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -371,8 +371,8 @@ Y_UNIT_TEST_SUITE(KqpWrite) {
UNIT_ASSERT_VALUES_EQUAL(stats.query_phases().size(), 2);
}
- Y_UNIT_TEST_TWIN(CastValues, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(CastValues) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
@@ -406,8 +406,8 @@ Y_UNIT_TEST_SUITE(KqpWrite) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(CastValuesOptional, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(CastValuesOptional) {
+ auto kikimr = DefaultKikimrRunner();
auto db = kikimr.GetTableClient();
auto session = db.CreateSession().GetValueSync().GetSession();
diff --git a/ydb/core/kqp/ut/kqp_yql_ut.cpp b/ydb/core/kqp/ut/kqp_yql_ut.cpp
index cab2aac4450..9f819ba58c9 100644
--- a/ydb/core/kqp/ut/kqp_yql_ut.cpp
+++ b/ydb/core/kqp/ut/kqp_yql_ut.cpp
@@ -12,8 +12,8 @@ using namespace NYdb::NScripting;
using namespace NYdb::NTable;
Y_UNIT_TEST_SUITE(KqpYql) {
- Y_UNIT_TEST_TWIN(RefSelect, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(RefSelect) {
+ auto kikimr = DefaultKikimrRunner();
TScriptingClient client(kikimr.GetDriver());
auto result = client.ExecuteYqlScript(R"(
@@ -28,8 +28,8 @@ Y_UNIT_TEST_SUITE(KqpYql) {
UNIT_ASSERT(HasIssue(result.GetIssues(), NYql::TIssuesIds::DEFAULT_ERROR));
}
- Y_UNIT_TEST_TWIN(TableConcat, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(TableConcat) {
+ auto kikimr = DefaultKikimrRunner();
TScriptingClient client(kikimr.GetDriver());
auto result = client.ExecuteYqlScript(R"(
@@ -44,8 +44,8 @@ Y_UNIT_TEST_SUITE(KqpYql) {
UNIT_ASSERT(HasIssue(result.GetIssues(), NYql::TIssuesIds::DEFAULT_ERROR));
}
- Y_UNIT_TEST_TWIN(TableRange, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(TableRange) {
+ auto kikimr = DefaultKikimrRunner();
TScriptingClient client(kikimr.GetDriver());
auto result = client.ExecuteYqlScript(R"(
@@ -60,8 +60,8 @@ Y_UNIT_TEST_SUITE(KqpYql) {
UNIT_ASSERT(HasIssue(result.GetIssues(), NYql::TIssuesIds::DEFAULT_ERROR));
}
- Y_UNIT_TEST_TWIN(TableUseBeforeCreate, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(TableUseBeforeCreate) {
+ auto kikimr = DefaultKikimrRunner();
TScriptingClient client(kikimr.GetDriver());
auto result = client.ExecuteYqlScript(R"(
@@ -83,8 +83,8 @@ Y_UNIT_TEST_SUITE(KqpYql) {
UNIT_ASSERT(HasIssue(result.GetIssues(), NYql::TIssuesIds::DEFAULT_ERROR));
}
- Y_UNIT_TEST_TWIN(ColumnNameConflict, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(ColumnNameConflict) {
+ auto kikimr = DefaultKikimrRunner();
TScriptingClient client(kikimr.GetDriver());
auto result = client.ExecuteYqlScript(R"(
@@ -103,8 +103,8 @@ Y_UNIT_TEST_SUITE(KqpYql) {
UNIT_ASSERT(HasIssue(result.GetIssues(), NYql::TIssuesIds::DEFAULT_ERROR));
}
- Y_UNIT_TEST_TWIN(TableNameConflict, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(TableNameConflict) {
+ auto kikimr = DefaultKikimrRunner();
TScriptingClient client(kikimr.GetDriver());
auto result = client.ExecuteYqlScript(R"(
@@ -132,8 +132,8 @@ Y_UNIT_TEST_SUITE(KqpYql) {
UNIT_ASSERT(HasIssue(result.GetIssues(), NYql::TIssuesIds::DEFAULT_ERROR));
}
- Y_UNIT_TEST_TWIN(DdlDmlMix, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(DdlDmlMix) {
+ auto kikimr = DefaultKikimrRunner();
TScriptingClient client(kikimr.GetDriver());
auto result = client.ExecuteYqlScript(R"(
@@ -147,8 +147,8 @@ Y_UNIT_TEST_SUITE(KqpYql) {
UNIT_ASSERT(HasIssue(result.GetIssues(), NYql::TIssuesIds::KIKIMR_MIXED_SCHEME_DATA_TX));
}
- Y_UNIT_TEST_TWIN(ScriptUdf, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(ScriptUdf) {
+ auto kikimr = DefaultKikimrRunner();
TScriptingClient client(kikimr.GetDriver());
auto result = client.ExecuteYqlScript(R"(
@@ -169,8 +169,8 @@ Y_UNIT_TEST_SUITE(KqpYql) {
UNIT_ASSERT(HasIssue(result.GetIssues(), NYql::TIssuesIds::DEFAULT_ERROR));
}
- Y_UNIT_TEST_TWIN(UpdatePk, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(UpdatePk) {
+ auto kikimr = DefaultKikimrRunner();
TScriptingClient client(kikimr.GetDriver());
auto result = client.ExecuteYqlScript(R"(
@@ -186,8 +186,8 @@ Y_UNIT_TEST_SUITE(KqpYql) {
UNIT_ASSERT(HasIssue(result.GetIssues(), NYql::TIssuesIds::DEFAULT_ERROR));
}
- Y_UNIT_TEST_TWIN(UpdateBadType, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(UpdateBadType) {
+ auto kikimr = DefaultKikimrRunner();
TScriptingClient client(kikimr.GetDriver());
auto result = client.ExecuteYqlScript(R"(
@@ -202,8 +202,8 @@ Y_UNIT_TEST_SUITE(KqpYql) {
UNIT_ASSERT(HasIssue(result.GetIssues(), NYql::TIssuesIds::DEFAULT_ERROR));
}
- Y_UNIT_TEST_TWIN(InsertCV, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(InsertCV) {
+ auto kikimr = DefaultKikimrRunner();
TScriptingClient client(kikimr.GetDriver());
auto result = client.ExecuteYqlScript(R"(
@@ -217,8 +217,8 @@ Y_UNIT_TEST_SUITE(KqpYql) {
UNIT_ASSERT(HasIssue(result.GetIssues(), NYql::TIssuesIds::KIKIMR_CONSTRAINT_VIOLATION));
}
- Y_UNIT_TEST_TWIN(InsertCVList, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(InsertCVList) {
+ auto kikimr = DefaultKikimrRunner();
TScriptingClient client(kikimr.GetDriver());
auto result = client.ExecuteYqlScript(R"(
@@ -234,8 +234,8 @@ Y_UNIT_TEST_SUITE(KqpYql) {
UNIT_ASSERT(HasIssue(result.GetIssues(), NYql::TIssuesIds::KIKIMR_CONSTRAINT_VIOLATION));
}
- Y_UNIT_TEST_TWIN(InsertIgnore, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(InsertIgnore) {
+ auto kikimr = DefaultKikimrRunner();
TScriptingClient client(kikimr.GetDriver());
auto result = client.ExecuteYqlScript(R"(
@@ -268,8 +268,8 @@ Y_UNIT_TEST_SUITE(KqpYql) {
UNIT_ASSERT(HasIssue(result.GetIssues(), NYql::TIssuesIds::KIKIMR_READ_MODIFIED_TABLE));
}
- Y_UNIT_TEST_TWIN(UnwrapReadTableValues, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(UnwrapReadTableValues) {
+ auto kikimr = DefaultKikimrRunner();
TScriptingClient client(kikimr.GetDriver());
auto result = client.ExecuteYqlScript(R"(
@@ -284,8 +284,8 @@ Y_UNIT_TEST_SUITE(KqpYql) {
])", FormatResultSetYson(result.GetResultSet(0)));
}
- Y_UNIT_TEST_TWIN(CreateUseTable, UseSessionActor) {
- auto kikimr = KikimrRunnerEnableSessionActor(UseSessionActor);
+ Y_UNIT_TEST(CreateUseTable) {
+ auto kikimr = DefaultKikimrRunner();
TScriptingClient client(kikimr.GetDriver());
auto result = client.ExecuteYqlScript(R"(
diff --git a/ydb/core/testlib/test_client.h b/ydb/core/testlib/test_client.h
index 2401c11e54c..b69246cd534 100644
--- a/ydb/core/testlib/test_client.h
+++ b/ydb/core/testlib/test_client.h
@@ -135,11 +135,6 @@ namespace Tests {
std::function<IActor*(const NKikimrProto::TAuthConfig&)> CreateTicketParser = NKikimr::CreateTicketParser;
std::shared_ptr<TGrpcServiceFactory> GrpcServiceFactory;
- TServerSettings& SetEnableKqpSessionActor(bool enable) {
- AppConfig.MutableTableServiceConfig()->SetEnableKqpSessionActor(enable);
- return *this;
- }
-
TServerSettings& SetGrpcPort(ui16 value) { GrpcPort = value; return *this; }
TServerSettings& SetSupportsRedirect(bool value) { SupportsRedirect = value; return *this; }
TServerSettings& SetTracePath(const TString& value) { TracePath = value; return *this; }
diff --git a/ydb/core/tx/columnshard/ut_columnshard_tiers.cpp b/ydb/core/tx/columnshard/ut_columnshard_tiers.cpp
index 7b407936d1e..851166f30d4 100644
--- a/ydb/core/tx/columnshard/ut_columnshard_tiers.cpp
+++ b/ydb/core/tx/columnshard/ut_columnshard_tiers.cpp
@@ -206,7 +206,6 @@ Y_UNIT_TEST_SUITE(ColumnShardTiers) {
serverSettings.SetDomainName("Root")
.SetUseRealThreads(false)
.SetEnableMetadataProvider(true)
- .SetEnableKqpSessionActor(true)
.SetEnableOlapSchemaOperations(true);
;
@@ -280,7 +279,6 @@ Y_UNIT_TEST_SUITE(ColumnShardTiers) {
serverSettings.SetDomainName("Root")
.SetUseRealThreads(false)
.SetEnableMetadataProvider(true)
- .SetEnableKqpSessionActor(true)
.SetEnableOlapSchemaOperations(true);
;
diff --git a/ydb/core/tx/datashard/datashard_ut_kqp_errors.cpp b/ydb/core/tx/datashard/datashard_ut_kqp_errors.cpp
index 75aa10c5392..ad2af0255ec 100644
--- a/ydb/core/tx/datashard/datashard_ut_kqp_errors.cpp
+++ b/ydb/core/tx/datashard/datashard_ut_kqp_errors.cpp
@@ -39,7 +39,6 @@ public:
TServerSettings serverSettings(pm.GetPort(2134));
serverSettings.SetDomainName("Root")
.SetNodeCount(2)
- .SetEnableKqpSessionActor(true)
.SetUseRealThreads(false);
Server = new TServer(serverSettings);
diff --git a/ydb/core/tx/datashard/datashard_ut_order.cpp b/ydb/core/tx/datashard/datashard_ut_order.cpp
index 579542a44b2..11519a94946 100644
--- a/ydb/core/tx/datashard/datashard_ut_order.cpp
+++ b/ydb/core/tx/datashard/datashard_ut_order.cpp
@@ -1241,7 +1241,6 @@ Y_UNIT_TEST_TWIN(TestDelayedTxWaitsForWriteActiveTxOnly, UseMvcc) {
TServerSettings serverSettings(pm.GetPort(2134));
serverSettings.SetDomainName("Root")
.SetEnableMvcc(WithMvcc)
- .SetEnableKqpSessionActor(true)
.SetUseRealThreads(false);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -1334,7 +1333,6 @@ Y_UNIT_TEST_TWIN(TestOnlyDataTxLagCausesRejects, UseMvcc) {
TServerSettings serverSettings(pm.GetPort(2134));
serverSettings.SetDomainName("Root")
.SetEnableMvcc(WithMvcc)
- .SetEnableKqpSessionActor(true)
.SetUseRealThreads(false);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -1420,7 +1418,6 @@ Y_UNIT_TEST_TWIN(TestOutOfOrderLockLost, UseMvcc) {
TServerSettings serverSettings(pm.GetPort(2134));
serverSettings.SetDomainName("Root")
.SetEnableMvcc(WithMvcc)
- .SetEnableKqpSessionActor(true)
.SetUseRealThreads(false);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -1554,7 +1551,6 @@ Y_UNIT_TEST(TestMvccReadDoesntBlockWrites) {
TServerSettings serverSettings(pm.GetPort(2134));
serverSettings.SetDomainName("Root")
.SetEnableMvcc(true)
- .SetEnableKqpSessionActor(true)
.SetUseRealThreads(false);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -1693,7 +1689,6 @@ Y_UNIT_TEST_TWIN(TestOutOfOrderReadOnlyAllowed, UseMvcc) {
TServerSettings serverSettings(pm.GetPort(2134));
serverSettings.SetDomainName("Root")
.SetEnableMvcc(WithMvcc)
- .SetEnableKqpSessionActor(true)
.SetUseRealThreads(false);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -1804,7 +1799,6 @@ Y_UNIT_TEST_TWIN(TestOutOfOrderNonConflictingWrites, UseMvcc) {
TServerSettings serverSettings(pm.GetPort(2134));
serverSettings.SetDomainName("Root")
.SetEnableMvcc(WithMvcc)
- .SetEnableKqpSessionActor(true)
.SetUseRealThreads(false);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -1921,7 +1915,6 @@ Y_UNIT_TEST(TestOutOfOrderRestartLocksSingleWithoutBarrier) {
TServerSettings serverSettings(pm.GetPort(2134));
serverSettings.SetDomainName("Root")
.SetEnableMvcc(false) // intentionally, because we test non-mvcc locks logic
- .SetEnableKqpSessionActor(true)
.SetUseRealThreads(false);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -2067,7 +2060,6 @@ Y_UNIT_TEST(MvccTestOutOfOrderRestartLocksSingleWithoutBarrier) {
TServerSettings serverSettings(pm.GetPort(2134));
serverSettings.SetDomainName("Root")
.SetEnableMvcc(true)
- .SetEnableKqpSessionActor(true)
.SetUseRealThreads(false);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -2209,7 +2201,6 @@ Y_UNIT_TEST_TWIN(TestOutOfOrderRestartLocksReorderedWithoutBarrier, UseMvcc) {
TServerSettings serverSettings(pm.GetPort(2134));
serverSettings.SetDomainName("Root")
.SetEnableMvcc(WithMvcc)
- .SetEnableKqpSessionActor(true)
.SetUseRealThreads(false);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -2356,7 +2347,6 @@ Y_UNIT_TEST_TWIN(TestOutOfOrderNoBarrierRestartImmediateLongTail, UseMvcc) {
TServerSettings serverSettings(pm.GetPort(2134));
serverSettings.SetDomainName("Root")
.SetEnableMvcc(WithMvcc)
- .SetEnableKqpSessionActor(true)
.SetUseRealThreads(false);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -2546,7 +2536,6 @@ Y_UNIT_TEST_TWIN(TestCopyTableNoDeadlock, UseMvcc) {
TServerSettings serverSettings(pm.GetPort(2134));
serverSettings.SetDomainName("Root")
.SetEnableMvcc(WithMvcc)
- .SetEnableKqpSessionActor(true)
.SetUseRealThreads(false);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -2730,7 +2719,6 @@ Y_UNIT_TEST(TestPlannedCancelSplit) {
TPortManager pm;
TServerSettings serverSettings(pm.GetPort(2134));
serverSettings.SetDomainName("Root")
- .SetEnableKqpSessionActor(true)
.SetUseRealThreads(false);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -2919,7 +2907,6 @@ Y_UNIT_TEST_TWIN(TestPlannedTimeoutSplit, UseMvcc) {
TServerSettings serverSettings(pm.GetPort(2134));
serverSettings.SetDomainName("Root")
.SetEnableMvcc(WithMvcc)
- .SetEnableKqpSessionActor(true)
.SetUseRealThreads(false);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -3039,7 +3026,6 @@ Y_UNIT_TEST_TWIN(TestPlannedHalfOverloadedSplit, UseMvcc) {
TServerSettings serverSettings(pm.GetPort(2134));
serverSettings.SetDomainName("Root")
.SetEnableMvcc(WithMvcc)
- .SetEnableKqpSessionActor(true)
.SetUseRealThreads(false);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -3206,7 +3192,6 @@ Y_UNIT_TEST(TestReadTableWriteConflict) {
TPortManager pm;
TServerSettings serverSettings(pm.GetPort(2134));
serverSettings.SetDomainName("Root")
- .SetEnableKqpSessionActor(true)
.SetUseRealThreads(false);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -3357,7 +3342,6 @@ Y_UNIT_TEST(TestReadTableImmediateWriteBlock) {
TPortManager pm;
TServerSettings serverSettings(pm.GetPort(2134));
serverSettings.SetDomainName("Root")
- .SetEnableKqpSessionActor(true)
.SetUseRealThreads(false);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -3429,7 +3413,6 @@ Y_UNIT_TEST_TWIN(TestReadTableSingleShardImmediate, WithMvcc) {
TServerSettings serverSettings(pm.GetPort(2134));
serverSettings.SetDomainName("Root")
.SetEnableMvcc(WithMvcc)
- .SetEnableKqpSessionActor(true)
.SetUseRealThreads(false);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -3477,7 +3460,6 @@ Y_UNIT_TEST(TestImmediateQueueThenSplit) {
TPortManager pm;
TServerSettings serverSettings(pm.GetPort(2134));
serverSettings.SetDomainName("Root")
- .SetEnableKqpSessionActor(true)
.SetUseRealThreads(false);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -3769,7 +3751,6 @@ Y_UNIT_TEST(MvccTestSnapshotRead) {
TServerSettings serverSettings(pm.GetPort(2134));
serverSettings.SetDomainName("Root")
.SetEnableMvcc(true)
- .SetEnableKqpSessionActor(true)
.SetUseRealThreads(false);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -3896,7 +3877,6 @@ Y_UNIT_TEST(TestSecondaryClearanceAfterShardRestartRace) {
TPortManager pm;
TServerSettings serverSettings(pm.GetPort(2134));
serverSettings.SetDomainName("Root")
- .SetEnableKqpSessionActor(true)
.SetUseRealThreads(false);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -3983,7 +3963,6 @@ Y_UNIT_TEST_TWIN(TestShardRestartNoUndeterminedImmediate, UseMvcc) {
TServerSettings serverSettings(pm.GetPort(2134));
serverSettings.SetDomainName("Root")
.SetEnableMvcc(WithMvcc)
- .SetEnableKqpSessionActor(true)
.SetUseRealThreads(false);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -4095,7 +4074,6 @@ Y_UNIT_TEST_TWIN(TestShardRestartPlannedCommitShouldSucceed, UseMvcc) {
TServerSettings serverSettings(pm.GetPort(2134));
serverSettings.SetDomainName("Root")
.SetEnableMvcc(WithMvcc)
- .SetEnableKqpSessionActor(true)
.SetUseRealThreads(false);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -4192,7 +4170,6 @@ Y_UNIT_TEST(TestShardSnapshotReadNoEarlyReply) {
serverSettings.SetDomainName("Root")
.SetEnableMvcc(true)
.SetEnableMvccSnapshotReads(true)
- .SetEnableKqpSessionActor(true)
.SetUseRealThreads(false);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -4337,7 +4314,6 @@ Y_UNIT_TEST(TestSnapshotReadAfterBrokenLock) {
serverSettings.SetDomainName("Root")
.SetEnableMvcc(true)
.SetEnableMvccSnapshotReads(true)
- .SetEnableKqpSessionActor(true)
.SetUseRealThreads(false);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -4410,7 +4386,6 @@ Y_UNIT_TEST(TestSnapshotReadAfterBrokenLockOutOfOrder) {
serverSettings.SetDomainName("Root")
.SetEnableMvcc(true)
.SetEnableMvccSnapshotReads(true)
- .SetEnableKqpSessionActor(true)
.SetUseRealThreads(false);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -4539,7 +4514,6 @@ Y_UNIT_TEST(TestSnapshotReadAfterStuckRW) {
serverSettings.SetDomainName("Root")
.SetEnableMvcc(true)
.SetEnableMvccSnapshotReads(true)
- .SetEnableKqpSessionActor(true)
.SetUseRealThreads(false);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -4638,7 +4612,6 @@ Y_UNIT_TEST_TWIN(TestSnapshotReadPriority, UnprotectedReads) {
serverSettings.SetDomainName("Root")
.SetEnableMvcc(true)
.SetEnableMvccSnapshotReads(true)
- .SetEnableKqpSessionActor(true)
.SetControls(controls)
.SetUseRealThreads(false);
@@ -4957,7 +4930,6 @@ Y_UNIT_TEST(TestUnprotectedReadsThenWriteVisibility) {
.SetNodeCount(2)
.SetEnableMvcc(true)
.SetEnableMvccSnapshotReads(true)
- .SetEnableKqpSessionActor(true)
.SetControls(controls)
.SetUseRealThreads(false);
@@ -5171,7 +5143,6 @@ Y_UNIT_TEST(UncommittedReadSetAck) {
TServerSettings serverSettings(pm.GetPort(2134));
serverSettings.SetDomainName("Root")
.SetNodeCount(2)
- .SetEnableKqpSessionActor(true)
.SetUseRealThreads(false);
@@ -5414,7 +5385,6 @@ Y_UNIT_TEST(UncommittedReads) {
serverSettings.SetDomainName("Root")
.SetEnableMvcc(true)
.SetEnableMvccSnapshotReads(true)
- .SetEnableKqpSessionActor(true)
.SetControls(controls)
.SetUseRealThreads(false);
diff --git a/ydb/core/tx/datashard/datashard_ut_snapshot.cpp b/ydb/core/tx/datashard/datashard_ut_snapshot.cpp
index 29574c8dab0..88a7364530f 100644
--- a/ydb/core/tx/datashard/datashard_ut_snapshot.cpp
+++ b/ydb/core/tx/datashard/datashard_ut_snapshot.cpp
@@ -988,7 +988,6 @@ Y_UNIT_TEST_SUITE(DataShardSnapshots) {
.SetUseRealThreads(false)
.SetEnableMvcc(true)
.SetEnableMvccSnapshotReads(true)
- .SetEnableKqpSessionActor(true)
.SetKeepSnapshotTimeout(TDuration::Seconds(2))
.SetControls(controls);
@@ -1096,7 +1095,6 @@ Y_UNIT_TEST_SUITE(DataShardSnapshots) {
.SetUseRealThreads(false)
.SetEnableMvcc(true)
.SetEnableMvccSnapshotReads(true)
- .SetEnableKqpSessionActor(true)
.SetControls(controls);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -1293,7 +1291,6 @@ Y_UNIT_TEST_SUITE(DataShardSnapshots) {
.SetUseRealThreads(false)
.SetEnableMvcc(true)
.SetEnableMvccSnapshotReads(true)
- .SetEnableKqpSessionActor(true)
.SetControls(controls);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -1660,7 +1657,6 @@ Y_UNIT_TEST_SUITE(DataShardSnapshots) {
.SetUseRealThreads(false)
.SetEnableMvcc(true)
.SetEnableMvccSnapshotReads(true)
- .SetEnableKqpSessionActor(true)
.SetControls(controls);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -1765,7 +1761,6 @@ Y_UNIT_TEST_SUITE(DataShardSnapshots) {
.SetUseRealThreads(false)
.SetEnableMvcc(true)
.SetEnableMvccSnapshotReads(true)
- .SetEnableKqpSessionActor(true)
.SetControls(controls);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -1877,7 +1872,6 @@ Y_UNIT_TEST_SUITE(DataShardSnapshots) {
.SetUseRealThreads(false)
.SetEnableMvcc(true)
.SetEnableMvccSnapshotReads(true)
- .SetEnableKqpSessionActor(true)
.SetControls(controls);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -2018,7 +2012,6 @@ Y_UNIT_TEST_SUITE(DataShardSnapshots) {
.SetUseRealThreads(false)
.SetEnableMvcc(true)
.SetEnableMvccSnapshotReads(true)
- .SetEnableKqpSessionActor(true)
.SetControls(controls);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -2193,7 +2186,6 @@ Y_UNIT_TEST_SUITE(DataShardSnapshots) {
.SetUseRealThreads(false)
.SetEnableMvcc(true)
.SetEnableMvccSnapshotReads(true)
- .SetEnableKqpSessionActor(true)
.SetControls(controls);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -2356,7 +2348,6 @@ Y_UNIT_TEST_SUITE(DataShardSnapshots) {
.SetUseRealThreads(false)
.SetEnableMvcc(true)
.SetEnableMvccSnapshotReads(true)
- .SetEnableKqpSessionActor(true)
.SetControls(controls);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -2513,7 +2504,6 @@ Y_UNIT_TEST_SUITE(DataShardSnapshots) {
.SetUseRealThreads(false)
.SetEnableMvcc(true)
.SetEnableMvccSnapshotReads(true)
- .SetEnableKqpSessionActor(true)
.SetControls(controls);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -2616,7 +2606,6 @@ Y_UNIT_TEST_SUITE(DataShardSnapshots) {
.SetUseRealThreads(false)
.SetEnableMvcc(true)
.SetEnableMvccSnapshotReads(true)
- .SetEnableKqpSessionActor(true)
.SetControls(controls);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -2706,7 +2695,6 @@ Y_UNIT_TEST_SUITE(DataShardSnapshots) {
.SetUseRealThreads(false)
.SetEnableMvcc(true)
.SetEnableMvccSnapshotReads(true)
- .SetEnableKqpSessionActor(true)
.SetControls(controls);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -2820,7 +2808,6 @@ Y_UNIT_TEST_SUITE(DataShardSnapshots) {
.SetUseRealThreads(false)
.SetEnableMvcc(true)
.SetEnableMvccSnapshotReads(true)
- .SetEnableKqpSessionActor(true)
.SetControls(controls);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -2940,7 +2927,6 @@ Y_UNIT_TEST_SUITE(DataShardSnapshots) {
.SetUseRealThreads(false)
.SetEnableMvcc(true)
.SetEnableMvccSnapshotReads(true)
- .SetEnableKqpSessionActor(true)
.SetControls(controls);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -3065,7 +3051,6 @@ Y_UNIT_TEST_SUITE(DataShardSnapshots) {
.SetUseRealThreads(false)
.SetEnableMvcc(true)
.SetEnableMvccSnapshotReads(true)
- .SetEnableKqpSessionActor(true)
.SetControls(controls);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -3249,7 +3234,6 @@ Y_UNIT_TEST_SUITE(DataShardSnapshots) {
.SetUseRealThreads(false)
.SetEnableMvcc(true)
.SetEnableMvccSnapshotReads(true)
- .SetEnableKqpSessionActor(true)
.SetControls(controls);
Tests::TServer::TPtr server = new TServer(serverSettings);
@@ -3351,7 +3335,6 @@ Y_UNIT_TEST_SUITE(DataShardSnapshots) {
.SetUseRealThreads(false)
.SetEnableMvcc(true)
.SetEnableMvccSnapshotReads(true)
- .SetEnableKqpSessionActor(true)
.SetControls(controls);
Tests::TServer::TPtr server = new TServer(serverSettings);