diff options
| author | va-kuznecov <va-kuznecov@ydb.tech> | 2023-05-22 09:58:29 +0300 |
|---|---|---|
| committer | va-kuznecov <va-kuznecov@ydb.tech> | 2023-05-22 09:58:29 +0300 |
| commit | 49ac4f1806336f9e9bf208c0f690b257420c3dc5 (patch) | |
| tree | 939129ae2bacc8af1aa07d86dd28077500230d5a | |
| parent | 1adca918f6d75cefd276edfcb74f9560a85de778 (diff) | |
| download | ydb-49ac4f1806336f9e9bf208c0f690b257420c3dc5.tar.gz | |
Enable UT reproducing Range* nodes datarace YQL-15582
| -rw-r--r-- | ydb/core/kqp/ut/service/kqp_service_ut.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/ydb/core/kqp/ut/service/kqp_service_ut.cpp b/ydb/core/kqp/ut/service/kqp_service_ut.cpp index 75e36d556b8..f1fc8bd688e 100644 --- a/ydb/core/kqp/ut/service/kqp_service_ut.cpp +++ b/ydb/core/kqp/ut/service/kqp_service_ut.cpp @@ -297,7 +297,7 @@ Y_UNIT_TEST_SUITE(KqpService) { auto kikimr = TKikimrRunner{settings}; auto driver = kikimr.GetDriver(); - size_t InFlight = 1; // use >1 to reproduce data race in Range* computation nodes + size_t InFlight = 10; NPar::LocalExecutor().RunAdditionalThreads(InFlight); NPar::LocalExecutor().ExecRange([&driver](int /*id*/) { TTimer t; @@ -309,7 +309,7 @@ Y_UNIT_TEST_SUITE(KqpService) { SELECT Key, Value FROM `/Root/KeyValue` WHERE Value = "One" AND Key IN $in )"); - for (ui32 i = 0; i < 200; ++i) { + for (ui32 i = 0; i < 20; ++i) { auto params = TParamsBuilder(); auto& pl = params.AddParam("$in").BeginList(); for (auto v : {1, 2, 3, 42, 50, 100}) { |