Skip to content

Commit c643673

Browse files
committed
YQ-4272 fixed race in compute scheduler (#19396)
1 parent f1686eb commit c643673

File tree

2 files changed

+5
-1
lines changed

2 files changed

+5
-1
lines changed

ydb/core/kqp/node_service/kqp_node_service.cpp

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -313,6 +313,10 @@ class TKqpNodeService : public TActorBootstrapped<TKqpNodeService> {
313313
ActorIdToProto(taskCtx.ComputeActorId, startedTask->MutableActorId());
314314
}
315315

316+
if (!schedulerGroup.empty()) {
317+
Scheduler->AdvanceTime(TlsActivationContext->Monotonic());
318+
}
319+
316320
TCPULimits cpuLimits;
317321
if (msg.GetPoolMaxCpuShare() > 0) {
318322
// Share <= 0 means disabled limit

ydb/core/kqp/runtime/kqp_compute_scheduler.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -228,7 +228,7 @@ class TObservableUpdater {
228228
template<typename T>
229229
class TParameter : public IObservableValue<T> {
230230
public:
231-
TParameter(TObservableUpdater* engine, double initialValue)
231+
TParameter(TObservableUpdater* engine, T initialValue)
232232
: Value_(initialValue)
233233
, Updater_(engine)
234234
{

0 commit comments

Comments
 (0)