aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorstanly <stanly@yandex-team.com>2023-05-24 16:32:41 +0300
committerstanly <stanly@yandex-team.com>2023-05-24 16:32:41 +0300
commit4edcb7784e89987328828200ed0a151880bf8cb3 (patch)
tree9991ee391611378dba1d7a8df02e70e788a3bb9a
parent938940585bd002f480d1a8c29cb707085c2af3a5 (diff)
downloadydb-4edcb7784e89987328828200ed0a151880bf8cb3.tar.gz
run compaction actors in the batch pool
-rw-r--r--ydb/core/tx/columnshard/columnshard.cpp5
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());