We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 26817c9 commit 695d696Copy full SHA for 695d696
ydb/core/kqp/runtime/kqp_compute_scheduler.cpp
@@ -498,9 +498,9 @@ class TSchedulerActor : public TActorBootstrapped<TSchedulerActor> {
498
NActors::TExecutorPoolStats poolStats;
499
TVector<NActors::TExecutorThreadStats> threadsStats;
500
TlsActivationContext->ActorSystem()->GetPoolStats(poolId, poolStats, threadsStats);
501
- Y_ENSURE(poolStats.MaxThreadCount > 0);
502
- Opts.Counters->SchedulerCapacity->Set(poolStats.MaxThreadCount);
503
- Opts.Scheduler->SetCapacity(poolStats.MaxThreadCount);
+ ui64 threads = Max<ui64>(poolStats.MaxThreadCount, 1);
+ Opts.Counters->SchedulerCapacity->Set(threads);
+ Opts.Scheduler->SetCapacity(threads);
504
}
505
506
STATEFN(State) {
0 commit comments