diff options
author | stanly <stanly@yandex-team.com> | 2023-05-24 16:32:41 +0300 |
---|---|---|
committer | stanly <stanly@yandex-team.com> | 2023-05-24 16:32:41 +0300 |
commit | 4edcb7784e89987328828200ed0a151880bf8cb3 (patch) | |
tree | 9991ee391611378dba1d7a8df02e70e788a3bb9a | |
parent | 938940585bd002f480d1a8c29cb707085c2af3a5 (diff) | |
download | ydb-4edcb7784e89987328828200ed0a151880bf8cb3.tar.gz |
run compaction actors in the batch pool
-rw-r--r-- | ydb/core/tx/columnshard/columnshard.cpp | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/ydb/core/tx/columnshard/columnshard.cpp b/ydb/core/tx/columnshard/columnshard.cpp index 1ce836f23b..a302eabc4e 100644 --- a/ydb/core/tx/columnshard/columnshard.cpp +++ b/ydb/core/tx/columnshard/columnshard.cpp @@ -27,7 +27,10 @@ void TColumnShard::SwitchToWork(const TActorContext& ctx) { LOG_S_INFO("Switched to work at " << TabletID() << " actor " << ctx.SelfID); IndexingActor = ctx.Register(CreateIndexingActor(TabletID(), ctx.SelfID)); - CompactionActor = ctx.Register(CreateCompactionActor(TabletID(), ctx.SelfID, TSettings::MAX_ACTIVE_COMPACTIONS)); + CompactionActor = ctx.Register( + CreateCompactionActor(TabletID(), ctx.SelfID, TSettings::MAX_ACTIVE_COMPACTIONS), + // Default mail-box and batch pool. + TMailboxType::HTSwap, AppData(ctx)->BatchPoolId); EvictionActor = ctx.Register(CreateEvictionActor(TabletID(), ctx.SelfID)); for (auto&& i : TablesManager.GetTables()) { ActivateTiering(i.first, i.second.GetTieringUsage()); |